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

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