本文介绍了Kafka Mirror Maker无法复制__consumer_offset主题的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我正在尝试使用镜像制作器来复制 __ consumre_offsets 主题以及其他主题。

I am trying to make use of mirror maker to replicate __consumre_offsets topic along with other topics.

它正在给出错误,如下所述。

It is giving error as mentioned below.

有什么方法可以解决这个问题?

Is there any way to resolve this?

在,它提到了复制偏移量主题数据中心。有人可以告诉我实现这一目标的可能方法吗?

In one of the confluent presentation in SlideShare on slide21, it mentioned about replicating offset topic in multiple datacenters. Can someone tell me the possible way to achieve the same?

或者还有其他更好的方法来备份和恢复Kafka的策略。

Or there is any other better way for backup and restore policy for Kafka.

推荐答案

将其添加到您的 consumer.config 中:

exclude.internal.topics=false

并将其添加到您的 producer.config

client.id=__admin_client


存在的原因是,除非您声明<$ c,否则制作人无法写内部主题$ c> client.id = __ admin_client ,由AdminClient.scala使用。在这里找到:

Reason being, Producers cannot write to internal topics unless you declare client.id=__admin_client which is used by AdminClient.scala. Found here: https://issues.apache.org/jira/browse/KAFKA-6524

这篇关于Kafka Mirror Maker无法复制__consumer_offset主题的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

07-28 02:46