我经营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最早。在中断时,旧线程被终止,新线程从更新的偏移量中读取数据,一些数据仍然保留在主题中,并且永远不会被拾取。任何建议。
暂无答案!
目前还没有任何答案,快来回答吧!