我在哪里/如何为 kafka 设置 acks

Question

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

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

Answer 1

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