如何将 kafkacat 有效负载打印输出转换为二进制
How to turn a kafkacat payload printout into binary
我可以使用 kafkacat 从主题中获取元组并将其打印出来：
kafkacat -b kafka10.myorg.com:9092 -t MyTopic -o -1 -f '%s\n'
然后我在我的终端中得到这样的信息：
�ǐے�ғ�����������ǐے�ғ���������S1_153314S3_153314S4_5422973S2_5420991...
我是否可以将打印出的有效载荷转换为二进制格式，以便我可以将其提供给我的本地代码进行调试？
您可以直接将消息作为二进制数据使用，而无需应用格式。
kafkacat -b kafka10-staging.salesforceiq.com:9092 -t MyTopic -o -1 -D "" > out.file
-D "" 的用法是为了避免将 "\n" 添加到二进制数据中。
https://github.com/edenhill/kafkacat/issues/72
我可以使用 kafkacat 从主题中获取元组并将其打印出来：
kafkacat -b kafka10.myorg.com:9092 -t MyTopic -o -1 -f '%s\n'
然后我在我的终端中得到这样的信息：
�ǐے�ғ�����������ǐے�ғ���������S1_153314S3_153314S4_5422973S2_5420991...
我是否可以将打印出的有效载荷转换为二进制格式，以便我可以将其提供给我的本地代码进行调试？
您可以直接将消息作为二进制数据使用，而无需应用格式。
kafkacat -b kafka10-staging.salesforceiq.com:9092 -t MyTopic -o -1 -D "" > out.file
-D "" 的用法是为了避免将 "\n" 添加到二进制数据中。 https://github.com/edenhill/kafkacat/issues/72