不同版本的Kafka集群进行同步时发现数据不对等且线程异常退出,怀疑是版本不对等。
org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request.
ERROR [mirrormaker-thread-0] Mirror maker thread failure due to (kafka.tools.MirrorMaker$MirrorMakerThread)
java.lang.IllegalStateException: Cannot perform operation after producer has been closed
at org.apache.kafka.clients.producer.KafkaProducer.throwIfProducerClosed(KafkaProducer.java:877)
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:886)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:870)
at kafka.tools.MirrorMaker$MirrorMakerProducer.send(MirrorMaker.scala:377)
at kafka.tools.MirrorMaker$MirrorMakerThread.$anonfun$run$4(MirrorMaker.scala:221)
at java.util.Collections$SingletonList.forEach(Collections.java:4822)
at kafka.tools.MirrorMaker$MirrorMakerThread.run(MirrorMaker.scala:221)
ERROR [mirrormaker-thread-0] Mirror maker thread exited abnormally, stopping the whole mirror maker. (kafka.tools.MirrorMaker$MirrorMakerThread)
地址没解开。
我发现只要在给本集群发送时才会又这个错误,mirrormaker和生产压测时,这个有什么解决方法吗?
域名解析异常,你可以参见一下这篇文章:
https://www.orchome.com/1903
好的,感谢
你的答案