kafka MirrorMaker不同版本的Kafka集群可以同步吗修订版本明细

源

采纳

编辑于 3年前

起风了

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

kafka

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

预览