腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
使用
Kafka
mirror
maker
复制
模式
?
、
、
我们正在
使用
mirror
maker
同步本地和AWS
Kafka
主题。在on-premise中注册了
模式
的主题
如何
在其他集群(本例中为AWS)中完全相同地
复制
?
如何
使用
mirror
maker
复制
Avro
模式
?
浏览 17
提问于2019-06-19
得票数 4
回答已采纳
1
回答
卡夫卡镜片制造工具出错[
kafka
版本0.10]
我试图
使用
镜像工具将数据从一个主集群
复制
到备份,但我得到了以下错误。nykpsr000001726$ bin/
kafka
-
mirror
-
maker
.sh --consumer.config config/
mirror
-consumer.properties --producer.config[mirrormaker-thread-0]
Mirror
maker
thread failure due to (
kafka</e
浏览 9
提问于2017-02-03
得票数 0
回答已采纳
1
回答
将消息从一个
Kafka
主题“推送”到另一个主题
、
、
因此,我的任务是建立一个
kafka
to
kafka
流媒体服务,我的公司将从我们的主题中发送
kafka
消息给客户
kafka
主题。 做这项工作最好的工具是什么?
浏览 12
提问于2021-07-16
得票数 0
1
回答
Kafka
数据从一台服务器
复制
到另一台服务器
、
、
、
我的
kafka
版本是0.8.2。现在我想将数据从服务器A
复制
到服务器B,然后期望服务器B中的
kafka
与服务器A中的
kafka
一样工作。我尝试
复制
$log.dirs中的所有数据,包括kafa-logs和zookeeper。但它不起作用。 有没有可能只
复制
一些数据文件,然后让它在服务器B中像在服务器A中一样正常工作?就像我从生产环境中
复制
sql转储文件并运行到我的本地mysql服务器中一样,它的工作方式与在生产环境服务器中相同。
浏览 0
提问于2015-11-19
得票数 2
1
回答
Mirror
Maker
不自动生成主题
我正在设置2个
kafka
簇之间的镜子制造器。 卡夫卡版本:
kafka
_2.11-2.1.0 我的server.properties有auto.create.topics.enable=true。我正在我的目标集群上运行
mirror
maker
。 但是当源集群添加一个主题时,新的主题不会自动创建。我最终不得不手动创建它们。一旦重新启动,它将在源上插入数据后立即开始
复制
。
Mirror
Maker
命令 ./
kafka
-
mirror</em
浏览 8
提问于2019-03-03
得票数 0
1
回答
KafkaMirrorMaker返回白名单选项的无效语法表达式
、
kafka
-
mirror
-
maker
.bat --consumer.config C:\\Users\\P9168308\\Documents\\consumerconfig.properties --P9168308\\Documents\\producerconfig.properties --whitelist "^Data_SfmcOfferAllocation_BEAM_Pluto_v1x00$" [2022-04-15 08:11:54,921] ERRO
浏览 13
提问于2022-04-15
得票数 -1
1
回答
Kafka
mirror
maker
无法正常工作
、
、
9092,source_broker_ip:9092 group.id=test-consumer-group_3bin/
kafka
-run-class.sh
kafka
.tools.MirrorMaker --consumer.config config/consume
浏览 0
提问于2018-05-22
得票数 1
1
回答
本地只写Cassandra节点
是否可以运行某种本地只写Cassandra节点(它
使用
最少的硬盘空间),它连接到其他节点,或者我必须通过某种消息总线运行?
浏览 2
提问于2016-06-24
得票数 1
1
回答
Kafka
-
如何
在第一个集群宕机时自动
使用
第二个集群?
、
我正在尝试
使用
mirror
maker
将数据从一个
kafka
集群
复制
到另一个
kafka
集群。假设主集群宕机,是否可以自动向第二个集群发送
kafka
消息?
浏览 1
提问于2017-04-11
得票数 2
1
回答
卡夫卡镜子制造商0.10.2.0不起作用
我
使用
卡夫卡0.10.2.0,我试图
使用
卡夫卡镜子制造者选项。consumer.properties:group.id=
mirror
_
maker
_2opt/
kafka
/bin/
kafka
-run-class.sh
kafka
.too
浏览 5
提问于2017-04-16
得票数 0
回答已采纳
2
回答
如何
在
kafka
中进行全
复制
?
、
如何
在
kafka
中进行全
复制
?
如何
确保当引导者拒绝(关闭)时,发送给跟随者的所有消息也会在打开后出现在引导者上。我知道启动时的一个选择:
Kafka
有一个内置的bin/
kafka
-
mirror
-
maker
.sh同步程序。它应该总是在领导者上运行,然后发送到它的消息也会发送到追随者。如果您同时在两台服务器上保留这些服务,消息将被无休止地
复制
。也就是说,由于同步,一条消息将不断地同时到
浏览 3
提问于2020-04-24
得票数 0
5
回答
如何
配置
Kafka
生产者的日志?
、
、
、
我
使用
的是
Kafka
producer客户端,我的项目中没有任何log4j配置。log4j.rootLogger=ERROR
如何
更改
Kafka
日志级别?
浏览 3
提问于2016-03-03
得票数 21
2
回答
Kafka
Mirror
Maker
未
复制
Counsumergroup偏移量
、
我们已经设置了MirrorMaker来跨两个
Kafka
集群
复制
消息。我们还在
mirror
maker
的消费者属性中设置了exclude.internal.topic=false,以
复制
内部主题。我假设这也将
复制
__consumer_offset topic,这将反过来同步辅助集群中的消费者组偏移量。但当我们在辅助集群中启动消费者组时,它从一开始就开始消费消息,所以看起来消费者组偏移量没有在辅助集群中
复制
。有没有人可以提供一些建议,比如我们
如何
使
浏览 0
提问于2019-11-27
得票数 0
1
回答
Kafka
Mirror
Maker
2偏移
复制
不起作用
、
我们正在测试
kafka
的灾难恢复场景。我们在不同的区域有2个
kafka
集群。我们
使用
MirrorMaker2来
复制
主题和消息。主题和消息是可以
复制
的。但我们观察到偏移量并没有
复制
。例如,从producuder中产生了10条指向
kafka
区域1的消息。消费了5条来自消费者的消息指向
kafka
区域1 停止消费者指向region1 开始消费者指向region2
使用
消息 这里的期望是区域2消费者应该从偏移量6开始消费 但是它从偏移量0开始消
浏览 42
提问于2020-09-24
得票数 2
1
回答
每个连接器/
使用
者的MM2配置
、
、
、
/bin/connect-
mirror
-
maker
.sh ./config/
mirror
-
maker
.properties 我有以下配置: clusters = A, Bssl.endpoint.identificati
浏览 28
提问于2020-06-12
得票数 0
1
回答
如何
在同一服务器或集群上运行两个多个
Kafka
Mirror
Maker
实例?
、
、
如何
在同一服务器或集群上运行两个多个
Kafka
Mirror
Maker
实例? 卡夫卡镜片制造者作为同步。
浏览 0
提问于2016-08-24
得票数 2
1
回答
信息预处理(主题-主题)-卡夫卡连接API与流对卡夫卡消费者?
、
、
、
我一直在研究
使用
Kafka
,因为它提供了很多有用的东西(配置管理、偏移存储、错误处理等等)。我是否应该单独
使用
SinkConnector,让我的SourceTask.put()完成所有写给卡夫卡的逻辑?
浏览 1
提问于2018-04-19
得票数 0
回答已采纳
1
回答
卡夫卡MirrorMaker灾难
基本上,MM正在
复制
比我需要的更多。
kafka
-
mirror
-
maker
.sh
kafka
.tools.MirrorMaker --consumer.config
kafka
-
mirror
-
maker
.sh
kafka
浏览 13
提问于2018-07-26
得票数 0
回答已采纳
1
回答
如何
获得多个镜像制造者节点来划分
复制
负载?
、
、
我试图在两个不同的
Kafka
集群(集群A和集群B)之间进行
复制
。我不需要活动/活动
复制
。从A→B出发对我来说就够了。为了实现这一目标,我计划建立一个镜像制造者2集群,如数据流,如下所示:集群A有接近3k的分区,它是业务关键应用程序的一部分,因此我必须保证A和B之间的快速
复制
。我开始尝试设置一个专用镜像制造商集群(即
使用
connect-
mirror
-
maker
.sh)。 提到“在这种
模式
下,MirrorMaker不
浏览 4
提问于2022-06-23
得票数 0
1
回答
Kafka
Streams -通过交互式查询在远程存储中进行查找的最佳方式?
、
我想要有一个
Kafka
Streams拓扑,它将有五个独立的KStreams从各自的主题读取数据,并将数据转储到一个大型的整体主题中。我想让这个物化的全局存储基本上作为其他
Kafka
Streams应用程序的“查找”表。我已经阅读了一些关于
使用
带有application.server配置的RPC层来公开这一点的文章,该RPC层将以一些独特的host:port的形式出现。让我们假设我对host:port上公开RPC层进行了硬编码,我该
如何
查询lookupStore才能明确地对其进行查询。如果这是在相同的拓扑/本地实
浏览 41
提问于2020-11-11
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何使用C+原型模式轻松实现对象复制和动态创建?
不惧流量持续上涨,BIGO 借助 Flink 与 Pulsar 打造实时消息系统
携程基于Mirror集群的自助性能测试实践
说说 MQ之Kafka(二)
Kafka 遇上 Spark Streaming
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券