ERROR consumer thread timing out (kafka.tools.ReplayLogProducer$ZKConsumerThrea 博客分类： kafka

程序员文章站 2024-03-19 15:54:28

...

执行kafka-replay-log-producer.sh --broker-list hadoop1:9092 --zookeeper hadoop1:2181 --inputtopic test --outputtopic test2

会报错

ERROR consumer thread timing out (kafka.tools.ReplayLogProducer$ZKConsumerThread)

kafka.consumer.ConsumerTimeoutException

at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:70)

at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:34)

at kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:64)

at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:56)

at scala.collection.Iterator$class.foreach(Iterator.scala:891)

at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:30)

at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)

at kafka.consumer.KafkaStream.foreach(KafkaStream.scala:27)

at kafka.tools.ReplayLogProducer$ZKConsumerThread.run(ReplayLogProducer.scala:137)

kafka-replay-log-producer.sh实现的功能是将消息test重发到test2，然而发现如果没有消息的话过几秒中就会抛出这个异常如果有消息就不会。