我正在尝试使用我当前的连接集群为mirror maker 2进行设置。基于此文档，可以通过connect rest api完成此操作。我按照示例发送了这个PUT请求： PUT /connectors/us-west-source/config HTTP/1.1 {
"name": "us-west-source","co
浏览 41提问于2020-04-24得票数 1
回答已采纳
我正在运行kafka mirror maker 2的一些用例。目前我让它在分布式模式下运行，复制“看起来”正在运行，但目标集群上的结果与源不匹配。 我的分布式prop文件包含以下内容。我非常确定这是正确的，因为当我将其设置为源集群时，它将在源集群上创建复制的主题 bootstrap.servers=**target-cluster:9092**clien
浏览 58提问于2021-04-01得票数 0
分布式服务启动成功: 2021-10-17 18:04:29,693 INFO Started Kafka {/，null，AVAILABLE} (org.apache.kafka.connect.runtime.rest.RestServer:319) 2021-10-17 18:04:29,693 INFO REST资源已初始化；服务器已启动，准备处理请求(org.apache.kafka.connect.runtime.rest.Res
浏览 38提问于2021-10-17得票数 2
我一直在研究使用Kafka，因为它提供了很多有用的东西(配置管理、偏移存储、错误处理等等)。我是否应该单独使用SinkConnector，让我的SourceTask.put()完成所有写给卡夫卡的逻辑？
浏览 1提问于2018-04-19得票数 0
回答已采纳
正在尝试将此架构id转换SMT ()应用到mirror maker群集，但它无法识别该SMT。如果我使用SMT作为kafka connect worker配置，它可以正常工作。我们使用Kafka 2.4/Confluent 5.4，并使用MM2进行复制。错误：
org.apache.kafka.connect.runtime.rest.errors.BadRequestE
浏览 11提问于2020-05-12得票数 1
我试图在两个集群之间设置复制，但不希望更改主题名称。如果我有一个名为"some_topic“的主题，它会自动复制到"cluster1.some_topic”中，我很确定这是可以完成的，但是还没有找到正确的配置来更改这个
# specify
浏览 3提问于2019-12-18得票数 10
回答已采纳
MirrorMaker2在卡夫卡和卡夫卡之间工作，但当我试图与EventHub同步时，没有骰子。 Message: Exceeded timeout of 300000ms while waiting for Deployment resource mirror-maker-eventhub-mirrormaker2,strimzi.io/name=mirror<
浏览 64提问于2022-03-15得票数 0
回答已采纳
我正在使用strimzi操作符并在k8上运行kafka集群。我想使用Kafka Mirror Maker，我使用CRD yml部署了Kafka Mirror Maker，但我的KMM的pod处于crashLoopBack状态。我不知道问题是什么？my-cluster2-zookeeper-2 1/1 Running
浏览 48提问于2020-11-20得票数 0
我试图在两个不同的Kafka集群(集群A和集群B)之间进行复制。我不需要活动/活动复制。从A→B出发对我来说就够了。为了实现这一目标，我计划建立一个镜像制造者2集群，如数据流，如下所示：集群A有接近3k的分区，它是业务关键应用程序的一部分，因此我必须保证A和B之间的快速复制。我开始尝试设置一个专用镜像制造商集群(即使用connect-mirror-maker.sh)。
提到“在这种模式下，MirrorMaker不
浏览 4提问于2022-06-23得票数 0
我正在使用在ubuntu .I上安装docker kafka connect我可以运行它，但是我不能在里面安装更多的连接器。2-还在connect-distributed.properties中添加了插件路径。怎么做到这一点有什么想法?？
浏览 2提问于2020-07-30得票数 2
我确实尝试了，但设置略有不同(没有停靠机，没有模式注册表)。docker run -d \ --net=kafka-connect_default \--expose 28083 \ -e CONNECT_BOOTSTRA
浏览 0提问于2020-03-11得票数 0
回答已采纳
1回答
在使用正式文档配置kafka连接之后.我必须尝试将.jar复制到上述目录，但什么也没有发生。 CONNECT_REST_PORT: 8083 CONNECT_CONFIG_STORAGE_TOPIC=class org.apache.kafka<
浏览 0提问于2021-05-19得票数 0
回答已采纳
我使用的是apache kafka，我使用的是连接器类com.github.castorm.kafka.connect.http.HttpSourceConnector这里是连接器的json文件 {, }
} 我也尝试了"connector.class"："com.tm.kafka.con
浏览 14提问于2020-09-06得票数 0
回答已采纳
我有一个简单的rest api (方法1)，它使用kafka-clients api生成发送到kafka集群的消息。Spring boot rest客户端库( kafka - -> producer.send ) -> kafka集群 此外，我还有另一个实现(方法2) Spring boot rest -> producer工厂实现(单一配置sp
浏览 17提问于2021-01-19得票数 0
回答已采纳
我正在尝试设置一个Kafka Mirror机制，但是似乎Kafka MirrorMaker的消费者在Kafka集群中只在镜像生成器进程启动时从新传入的数据中读取主题，即它不读取以前保存在主题中的历史数据我使用Kafka的MirrorMaker类来实现：
/bin/kafka-run-class.sh kafka.tools.MirrorMaker --consumer.config consumer.config：
浏览 0提问于2015-10-09得票数 4
则运行mirrormaker2 (connect-mirror-maker.sh mirrormaker.properties)时的日志输出不会显示此选项：我怎样才能正确地传递设置，这样生产者才能正确压缩？我还需要传递一些其他设置，但一旦此工作，它应该也为其他设置。
浏览 0提问于2021-10-12得票数 0
3回答
嗨，我现在正在用Docker设置Kafka。我已经成功地使用发布的融合图像设置了Zookeeper和Kafka，请参阅以下docker-compose文件： zookeeper: KAFKA_REST_ZOOKEEPER_CONNECT: 'zookeeper:2181'
KAFKA_
浏览 0提问于2017-03-27得票数 19
我已经设置了在两个DC之间复制数据的MirrorMaker2。connector.class = org.apache.kafka.connect.mirror.MirrorCheckpointConnector errors.tolerance = none
group.filter.class = class org.apache.kafka.connec
浏览 31提问于2020-02-16得票数 6
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
