Início / coding / Perguntas / 79549891
Accepted
TSSK
Asked: 2025-04-02 14:50:58 +0800 CST

Problema com cabeçalhos de linha de comando do Kafka Producer

  • 772

Estou tentando colocar uma mensagem em um tópico do Kafka. A mensagem contém cabeçalhos e um payload JSON.

Meu comando é assim:

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

Recebo o seguinte erro:

No headers delimiter found on line number 1
apache-kafka

1 respostas

  1. Best Answer

    Eu tive uma experiência muito melhor usando |como um delimitador entre o cabeçalho e o payload. Você pode tentar usar o comando abaixo, isso funciona com o payload e o cabeçalho que você compartilhou:

    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=|"

    É bom que você já tenha a parse.headerspropriedade. Eu também adicionei headers.delimiter=| para habilitar o uso de | como delimitador, e headers.key.separator== como seu cabeçalho usa =para separar chave e valor em vez de:

    • 1

relate perguntas