java - 在 Java 中哪里设置参数 min.insync.replicas 和 acks？

Question

我需要设置两个参数min.insync.replicas和acks. 官方文档说参数min.insync.replicas是broker的参数。我是否正确理解应该在 server.properties 文件中指定所有主题？其中之一 - 使用命令 kafka.config.sh。Acks参数只能在配置生产者时设置，例如从应用程序？对文件 producer.properties 的更改不会有帮助吗？

Answer 1

中定义的主题相关属性server.properties对所有主题都有效（假设您在创建主题时不修改任何配置）。

---

现在，如果出于某种原因您想修改特定主题的一个属性，您可以通过为该主题提供新配置来覆盖全局配置。例如，

bin/kafka-configs.sh \
    --zookeeper localhost:2181 \
    --alter \
    --entity-type topics \
    --entity-name yourTopicName \
    --add-config min.insync.replicas=2

---

或者，如果您想创建一个与您定义的配置不同的主题，server.properties您可以使用：

bin/kafka-topics.sh \
    --zookeeper localhost:2181 \
    --create \
    --topic yourTopicName \
    --partitions 1  \
    --replication-factor 3 \
    --config min.insync.replicas=2

---

最后，如果要验证配置是否有效，可以简单描述一下主题，添加的配置会显示在（Configs右上角）的输出中：

bin/kafka-topics \
    --zookeeper localhost:2181 \
    --describe  \
    --topic yourTopicName