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 abc-0, retrying (9 attempts left). Error: NETWORK_EXCEPTION 2017-12-07 06:18:02,675 ERROR oakspiRecordCollectorImpl [kafka-producer-network-thread | sample-app-0.0.1-7f99fa3f-4487-48dc-af3f-9296ee513452-StreamThread-1-producer] task [2_0] Error sending record (key 5a12c9ade532af0412fc7bcc.5a12c9ade532af0412fc7bca value com.sample.kafka.streams.SampleEvent@4a56c681 timestamp 1512363589768) to topic abc due to org.apache.kafka.common.errors.TimeoutException: Expiring 9 record(s) for abc-0: 189836 ms has passed since last append; No more records will be sent and no more offsets will be recorded for this task. 2017-12-07 06:18:02,927 INFO oakcciAbstractCoordinator [sample-app-0.0.1-7f99fa3f-4487-48dc-af3f-9296ee513452-StreamThread-1] [Consumer clientId=sample-app-0.0.1-7f99fa3f-4487-48dc-af3f-9296ee513452-StreamThread-1-consumer, groupId=sample-app-0.0.1] Discovered coordinator 1.1.1.1:32775 (id: 2147482645 rack: null)