ApacheKafka在轮询主题中的数据时发生中断异常

aamkag61  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(512)

我经营Kafka与多个消费者和多个主题,每个主题都有独特的消费群体,我得到的错误

Caused by: org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeThrowInterruptException(ConsumerNetworkClient.java:504) ~[kafka-clients-2.0.1.jar!/:?]
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:287) ~[kafka-clients-2.0.1.jar!/:?]
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242) ~[kafka-clients-2.0.1.jar!/:?]
    at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1247) ~[kafka-clients-2.0.1.jar!/:?]
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1187) ~[kafka-clients-2.0.1.jar!/:?]
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1154) ~[kafka-clients-2.0.1.jar!/:?]
    at com.hcl.journey.kafka.service.impl.ConsumerServiceImpl.read(ConsumerServiceImpl.java:61)

auto commit为false,auto.offset.reset最早。在中断时,旧线程被终止,新线程从更新的偏移量中读取数据,一些数据仍然保留在主题中,并且永远不会被拾取。任何建议。

暂无答案!

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

相关问题