kafka MirrorMaker不同版本的Kafka集群可以同步吗

起风了 发表于: 2021-05-27   最后更新时间: 2021-05-27 17:01:01   90 游览

不同版本的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)


发表于 24天前
添加评论

UnknownServerException

地址没解开。

起风了 -> 半兽人 23天前

我发现只要在给本集群发送时才会又这个错误,mirrormaker和生产压测时,这个有什么解决方法吗?

半兽人 -> 起风了 23天前

域名解析异常,你可以参见一下这篇文章:
https://www.orchome.com/1903

起风了 -> 半兽人 19天前

好的,感谢

找不到想要的答案?

我要提问
提问