在所有情况下,如果任何一个 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)
如果我遗漏了什么,请告诉我,如果我设置了怎么办transaction.state.log.min.isr=3?
提前致谢。
“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 ×2