Kafka镜子制造商未能复制消费者补偿主题

h7wcgrx3  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(373)

我正试图利用镜像机来复制 __consumer_offsets 主题以及其他主题。
它给出的错误如下所述。
[2018-10-24 16:16:03802]向主题发送消息时出错\u consumer \u offsets with key:16 bytes,value:445 bytes with error:(org.apache.kafka.clients.producer.internals.errorloggingcallback)org.apache.kafka.common.errors.invalidtopicexception:请求尝试对无效主题执行操作[2018-10-24 16:16:03828]向主题发送消息时出错\u consumer \u offset with key:29 bytes,value:754 bytes with error:(org.apache.kafka.clients.producer.internals.errorloggingcallback)org.apache.kafka.common.errors.invalidtopicexception:请求尝试对无效主题执行操作。
有什么办法解决这个问题吗?
在slideshare中关于slide21的一个合流演示中,它提到了在多个数据中心中复制偏移主题。有人能告诉我实现同样目标的可能方法吗?
或者,对于kafka的备份和恢复策略,还有其他更好的方法吗。

5jdjgkvh

5jdjgkvh1#

在consumer.config中添加以下内容:

exclude.internal.topics=false

并将其添加到producer.config中:

client.id=__admin_client

原因是,除非您声明 client.id=__admin_client 由adminclient.scala使用。在此处找到:https://issues.apache.org/jira/browse/kafka-6524

相关问题