主页 / coding / 问题 / 79549891
Accepted
TSSK
Asked: 2025-04-02 14:50:58 +0800 CST

Kafka Producer 命令行标题问题

  • 772

我正在尝试将消息发送到 kafka 主题。该消息包含标头和 JSON 有效负载。

我的命令是这样的：

echo 'headerKey1=value1;headerKey2=value2\t{\"myJson\":\"payload\"}' | ./bin/kafka-console-producer.sh \ --topic my-topic \ --bootstrapserver: myserver \ --property "parse.headers=true"

我收到以下错误：

No headers delimiter found on line number 1
apache-kafka

1 个回答

  1. Best Answer

    我在使用作为标头和有效负载之间的分隔符方面有更好的经验|。您可以尝试使用以下命令，它适用于您共享的有效负载和标头：

    echo 'headerKey1=value1,headerKey2=value2|{"myJson":"payload"}' | ./bin/kafka-console-producer.sh --topic my-topic --bootstrap-server myserver --property "parse.headers=true" --property "headers.key.separator==" --property "headers.delimiter=|"

    很高兴您已经拥有该parse.headers属性。我还添加了headers.delimiter=| 启用 | 作为分隔符的功能，headers.key.separator== 因为您的标头使用=| 来分隔键和值，而不是:

    • 1

相关问题