apache-kafka - 我在哪里/如何为 kafka 设置 ack

Question

在哪里可以为 Kafka 中的生产者设置 ack(确认)？我可以在 Cloudera Manager 中的 Kafka 配置中执行此操作吗？还是有某种特定的方法可以执行此操作？另外，如何查看已使用的现有 ack 的值？

我已经检查了文档here 。然而，它没有说明如何/在哪里设置这些选项。

Answer 1

我认为文档非常清楚。 ack 是生产者配置参数，因此当您在应用程序中创建生产者时，您必须设置“acks”属性(为 0、1 或全部)，并且需要向属性包提供所有参数(即引导代理列表) 、键序列化器、值序列化器等)。Ack 不是与集群本身或特定代理相关的参数，它是与生产者相关的参数，因此您可以让不同的生产者具有不同的 ack。