小编B R*_*ddy的帖子

transaction.state.log.min.isr 到底是什么意思?

在所有情况下,如果任何一个 Kafka 代理启动并运行,我的生产者和消费者都应该正常运行。

里面的参数server.properties如下,用于集群的高可用。

transaction.state.log.min.isr=2
offsets.topic.replication.factor=3
transaction.state.log.replication.factor=3
Run Code Online (Sandbox Code Playgroud)
  1. 如果所有 3 个 Kafka 代理(K1、K2 和 K3)均已启动,则集群运行良好。
  2. 如果 K1 和 K2 代理出现故障并且只有 K3 正常运行,则集群运行良好。
  3. 如果所有服务器都关闭并且我们启动 K1 Broker,集群将停止接收消息,消费者也会停止。

如果我遗漏了什么,请告诉我,如果我设置了怎么办transaction.state.log.min.isr=3

提前致谢。

apache-kafka

8
推荐指数
2
解决办法
9187
查看次数

在 Apache Kafka 中记录主题数据时使用 log.retention.bytes 参数的混乱

“log.retention.bytes”是我们用来保留主题消息日志的参数,我给定的值为 1073741824。

我参考了 Kafka 文档,其中提到“log.retention.bytes”中给出的大小是每个分区,所以这意味着假设如果我为我正在使用的所有主题有 20 个分区,那么 Kafka 的总字节大小根据文档,retain 是 20*1073741824 。

但我需要的是清晰的是

Will Kafka retain 20*1073741824 bytes for all the topics?
                     (or)
Will Kafka retain 20*1073741824 bytes per topic?
Run Code Online (Sandbox Code Playgroud)

apache-kafka

0
推荐指数
1
解决办法
1866
查看次数

标签 统计

apache-kafka ×2