Kafka连接超时60000ms后才能确定分区位置

tzxcd3kk  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(810)

使用kafka connect时,我面临消费者超时。但如果我使用Kafka控制台消费者没有错误。
[2020-06-24 14:54:37750]错误[consumer clientid=connector-consumer-simple-elasticsearch-connector-0,groupid=connect simple elasticsearch connector]用户提供的侦听器org.apache.kafka.connect.runtime.workersinktask$handlerebalance在调用为分区[simple.elasticsearch.data-dev-0](org.apache.kafka.clients.consumer.internals.consumerco)分配的onpartitionsas时失败ordinator:298)org.apache.kafka.common.errors.timeoutexception:错误:在确定simple.elasticsearch.data-dev-0分区的位置之前,超过60000ms的超时时间[2020-06-24 14:54:37,751]error workersinktask{id=simple-elasticsearch-connector-0}任务引发了未捕获且不可恢复的异常(org.apache.kafka.connect.runtime.workertask:187)org.apache.kafka.common.errors.timeoutexception:在确定simple.elasticsearch.data-dev-0分区位置之前,超过60000ms的超时[2020-06-24 14:54:37,752]error workersinktask{id=simple-elasticsearch-connector-0}任务被终止,在手动重新启动之前不会恢复(org.apache.kafka.connect.runtime.workertask:188)[2020-06-24 14:54:37752]停止elasticsearchsinktask的信息(io.confluent.connect.elasticsearch.elasticsearchsinktask:185)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题