腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
是否
可以
使用
java
更改
现有
kafka
主题
的
复制
因子
?
、
我正在
使用
AdminClient来改变
现有
kafka
主题
的
其他配置。但是我找不到一种方法来改变
主题
的
复制
因子
。有没有什么办法
可以
用
java
改变
复制
因子
?
浏览 23
提问于2019-06-11
得票数 3
回答已采纳
1
回答
不应用于状态存储
更改
主题
的
Kafka
流
复制
因子
、
、
我将
复制
因子
配置为在所有内部
Kafka
流
主题
中
使用
,方法是设置它适用于大多数由
Kafka
流在内部
使用
的
重新分区/变更
主题
。但是,该设置似乎对通过Materialized#as(StoreSupplier)手动创建
的</em
浏览 5
提问于2020-10-14
得票数 1
回答已采纳
1
回答
更改
日志/重新分区
主题
的
复制
因子
应该是多少
、
我知道
可以
为
kafka
streams配置
复制
因子
这些内部
主题
,我们
的
应用程序
使用
复制
因子
3作为常规应用程序
主题
,但到目前为止,我还没有为changelog/repartition
主题
配置
复制
因子
,而我
的
假设是,如果一个broker死亡(或由于某些原因领导者改变),
kafka
stream应用程序将自动重新平衡到新<e
浏览 6
提问于2019-03-04
得票数 3
4
回答
Kafka
:如何连接
kafka
-控制台-消费者获取远程代理
主题
内容?
、
、
、
、
我甚至
可以
做一个给我
的
bin/
kafka
-topics.sh --describe --zookeeper 172.X.X.X:2181 --topic remotetopic 然而,当我做bin/
kafka
-conso
浏览 5
提问于2015-11-07
得票数 15
1
回答
卡夫卡流内部
主题
复制
因素
的
变化会影响卡夫卡流吗?流
是否
处于错误状态?
、
我有两个
Kafka
流应用程序运行在两个不同
的
节点上。代理为5,
主题
的
复制
因子
为2,
更改
主题
的
复制
系数为2。现在,我希望增加或降低内部
主题
的
复制
因子
。这会影响我运行的卡夫卡流吗?
是否
必须重新启动应用程序才能进行
更改
,还是必须
更改
流
的
应用程序I?如果是,有什么充分
的</e
浏览 1
提问于2020-03-28
得票数 1
回答已采纳
1
回答
同一个
Kafka
topic中
的
分区
可以
有不同
的
复制
因子
吗?
、
在定义
kafka
主题
时,我
可以
设置
复制
因子
,通常
Kafka
会将分区分布在可用
的
代理上。假设我有3个代理,有一个
主题
,有几个分区,
复制
因子
=2,那么一些分区将设置在代理0,1上,一些分区设置在0,2上,一些分区设置在上 我
是否
可以
稍后仅设置一个分区
的
复制
因子
为3(并因此将此分区添加到剩余节点
使用
一个数字!=所有分
浏览 1
提问于2020-01-13
得票数 0
2
回答
如何在
kafka
-conect分发模式中手动定义
主题
分区和
复制
、
、
我
使用
sql-server
kafka
-connect和debezium来监视sql server数据库,但是当我发布并运行我
的
工作程序时,
主题
已经用名称{server_name}.{table_name}和默认
的
partitions=1 & replication=1创建了,即使我在"bootstrap.servers“参数中指定了两个代理。如何手动
更改
表
主题
的
分区和
复制
,或者在worker/connec
浏览 0
提问于2019-12-30
得票数 2
1
回答
在
Kafka
中增加
复制
因子
会产生错误--“存在一个正在运行
的
赋值”。
、
我试图按照Apache
Kafka
.In
的
顺序增加
主题
的
复制
因子
,因此我
使用
的
命令是最初,我
的
主题
有一个1
的
复制
因子
和5个分区,我试图将它
的</e
浏览 4
提问于2017-08-07
得票数 6
1
回答
Partitions w.r.t to broker和Partition相对于
主题
的
关联
我是
Kafka
的
新手,我正在尝试
使用
Kafka
开发企业级应用程序。在阅读文献时,我发现了一些关于每个代理
的
分区、
复制
因子
的
文档。当我尝试在broker上创建一个
主题
时,我
可以
改变no。每个
主题
的
分区、
复制
因子
。所以我
的
问题是
复制
因子
,分区在整个系统
的
上下文中是如何关联
浏览 0
提问于2019-03-02
得票数 0
1
回答
卡夫卡
是否
在所有经纪人中
复制
相同
的
数据?
我有一个用例,在这个用例中,在
Kafka
体系结构中有下面的组件。经纪人人数:5专题数目:3我必须实现
Kafka
集群
的
扩展,这意味着我希望
kafka
基础设施能够添加/删除/替换代理。添加/删除实例需要同步其他代理
的
整个数据,才能成为ISR(同步副本)。我们希望AWS自动标度来实现这一点,如果最终
Kafka
重新平衡某个分区
的
领导者并将其分配给这个新代理,我们实际上不希望跨可用性区域
使用</
浏览 0
提问于2018-12-19
得票数 3
1
回答
卡夫卡流-从KTable中消失
的
价值
、
发行背景 目前,我们正在
使用
:
Kafka
Streams API (版本1.1.0)来处理
Kafka
集群
的
消息(3个代理,每个
主题
3个分区,
复制
因子
2)。已安装
的
Kafka
版本为1.1.1。最终用户向我们报告数据消失
的
问题。他们报告说他们突然看不见任何数据。昨天他们
可以
在UI中看到n条记录,第二天早上
的
桌子是空
的
)。我们检查了这个特定用户
的
ch
浏览 1
提问于2018-09-19
得票数 4
1
回答
如何配置
Kafka
,让消费者和生产者在关闭
复制
时从故障中恢复?
、
、
、
我们有一个数据丢失是
可以
接受
的
用例(考虑30-50%
的
损失是
可以
接受
的
)。为了降低成本,我们想知道
是否
可以
将
Kafka
的
复制
因子
配置为1,这样消费者和生产者就
可以
通过简单地消费和生产可用分区来从代理故障中恢复。 如果这是可能
的
,需要设置哪些配置?还有其他代理技术天生就是这样
的
,然而,我们希望避免引入另一种技术,因为
kafka
已经
浏览 0
提问于2016-10-29
得票数 0
1
回答
Python KafkaProducer不能设置
复制
因子
、
、
事实上,在用
kafka
创建
主题
时,
可以
设置
复制
因子
,但是我
使用
的
是KafkaProducer (用于python
的
kafka
)。 我以为我
可以
做producer.send(...现在我只剩下一个选择,就是直接创建一个shell脚本来连接到
kafka
来创建一个
主题
,但是如果python
的
特性如此乏味,我为什么还要继续
使用
它呢?那么,当我要制作一个
浏览 1
提问于2018-01-15
得票数 0
回答已采纳
3
回答
无法创建许可证
主题
、
在
Kafka
启动时,多条消息记录到
kafka
/logs/kafkaServer.out并包含: Broker 0上
的
信息管理器:错误处理创建
主题
请求CreatableTopic(名称=‘_confluent-CreatableTopic:许可证
主题
,原因是:org.apache.
kafka
.common.errors.InvalidReplicationFactorException:
复制
因子
:3比可用代理大: 1. 2020-1
浏览 5
提问于2020-12-08
得票数 5
回答已采纳
1
回答
从磁盘全错误恢复
Kafka
群集
、
、
发生这种情况
的
原因是--我们把数据从文件拍重放到了卡夫卡的话题上,很多数据在很短
的
时间内就被推送出去了。我暂时将该
主题
的
保留从1 day
更改
为7 days,因此
主题
大小已变得正常。
kafka
[23949]: at
java
.nio.HeapByteBuffer.$anonfun$recover$1(LogSegment.scala:22 大多数
主题
的
复制
因子
要么是2,要么是3。所以
浏览 0
提问于2019-07-08
得票数 1
回答已采纳
2
回答
对
Kafka
集群设置
的
质疑
我有一个用例,我想先建立一个
Kafka
集群,一开始我有一个
Kafka
代理(A)和一个动物园管理员节点。因此,以下是我
的
质询: 如何
浏览 0
提问于2018-12-07
得票数 0
2
回答
基于Spring Boot
的
Kafka
集群容错
、
、
我开始在docker上
使用
Spring Boot
Kafka
和
kafka
集群。当我开始检查容错时,我就遇到了这个问题。通常,我通过Spring Boot中
的
Kafka
Admin创建一个
主题
(
复制
因子
= 2)。我能够存储一些消息,并从
Kafka
消费它们。我已经向bootstrap.servers属性提供了: SPRING_
KAFKA
_BOOTSTRAP_SERVERS:
kafka
:9092,<em
浏览 2
提问于2019-07-19
得票数 1
2
回答
修改
Kafka
主题
复制
因子
后会发生什么?
根据,您只需修改一个
主题
即可增加
复制
因子
。> bin/
kafka
-topics.sh --zookeeper zk_host:port/chroot --create --topic my_topic_name 不幸
的
是,它没有指定在您修改
主题
之后会发生什么。是将
现有
日志段
复制
到新副本,还是仅
复制</e
浏览 0
提问于2015-07-03
得票数 2
2
回答
如何从
Java
代码中获取
Kafka
主题
的
复制
因子
、
我有一些
主题
名称,我应该从我
的
Java
应用程序中获得有关它
的
复制
因子
的
信息。new String(zooKeeper.getData("/brokers/topics/" + KafkaTopicConfig.TOPIC_NAME, false, null));Top
浏览 3
提问于2020-03-03
得票数 2
回答已采纳
1
回答
卡夫卡物化观点
、
、
据我所知,卡夫卡默认情况下将在
主题
中保留记录7天,然后删除它们。但是卡夫卡物化
的
观点又如何呢,卡夫卡将把数据保存多久(不定式还是有限
的
时间)?同样,卡夫卡
是否
复制
了集群上
的
物化视图?
浏览 1
提问于2018-08-26
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
CDC Debezium 介绍
Kafka之安装部署
Kafka开发分布发布订阅消息系统学习路线
kafka sql入门
Apache Kafka 3.0.0持续更新共识机制KRaft,并着手清理旧支持与设置
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券