kafkacat is removing \0 when producing to a topic via pipe.

[4j4y]

I am consuming from a topic using Kafkacat and piping it to Kafkacat which produces to a different topic.If the consumed msg contains NUL char at the end, it is getting removed while producing.

Sample Message

nulltest.txt

Scenario

cat nulltest.txt | kafkacat -P -b localhost:9092 -t charon_test -D '' | kafkacat -C -b localhost:9092 -t charon_test -o -1 -c 1 -D '' | protoc --decode_raw

Output

Failed to parse input.

Expected Output

serialized proto message