Kafka HTTP 主题生产者配置 acks=all

Question

我们如何为 KAFKA HTTP 主题设置 acks=all？我尝试将以下 JSON 发送为“acks”：“all”，但它抛出了一个无法识别的属性。我也尝试在标题中设置它。但是在 Header 中，当我设置为 0,1、all 和 abcd 之类的任何值时。它接受所有的价值观。所以我不能依赖标题。但是从 Java 代码中，我们可以将此属性设置为 ProducerConfig.ACKS_CONFIG 作为键值对

{
    "records": [
        {
            "value": { "name": "Firstname, lastname" },
            "key":"123e4567-e89b-42d3-a456-5566424415123591"
        }
    ]
}

任何建议都有帮助。

Answer 1

在 Kafka REST 代理的情况下，生产者实例在客户端之间共享，即客户端将连接到 REST 代理实例，而这些 REST 代理实例将依次连接到 Kafka 集群（代理)。

您提供的json 只会包含数据记录。

REST 代理层将为您正在寻找的生产者提供全局设置，并且客户端最终将共享这些设置。因此，如果您可以访问 REST 代理实例，那么您可以直接在那里修改这些参数。