Tag: apache kafka streams

Kafkastream应用程序停止与org.apache.kafka.common.errors.TimeoutException

我已经在Dockercomposer php的帮助下安装了Kafka 1.0.0，并且我和两个经纪人成功地运行了这个Kafka。 我用分区手动创build了一个主题，并插入了事件。 现在我正在通过指向这个Kafka来运行带有1.0.0 Kafka Stream的应用程序。 在运行我的应用程序一段时间后，以下消息显示在日志中，并从运行停止。 除生产者request.timeout.ms外，其他所有configuration参数均为默认参数，生产者request.timeout.ms为120秒。 在下面的消息停止之前，我观察了几次'Trying to rejoin the consumer group now. org.apache.kafka.streams.errors.TaskMigratedException:' and 'Caused by: org.apache.kafka.clients.consumer.CommitFailedException:' 'Trying to rejoin the consumer group now. org.apache.kafka.streams.errors.TaskMigratedException:' and 'Caused by: org.apache.kafka.clients.consumer.CommitFailedException:'消息在日志中。 可能的原因是什么？ 请帮帮我。 停止之前的消息： 2017-12-07 06:17:03,122 WARN oakcpiSender [kafka-producer-network-thread | sample-app-0.0.1-7f99fa3f-4487-48dc-af3f-9296ee513452-StreamThread-1-producer] [Producer clientId=sample-app-0.0.1-7f99fa3f-4487-48dc-af3f-9296ee513452-StreamThread-1-producer] Got error produce response with sample id 14099 on topic-partition […]