我可以用 kafkacat
要从主题中获取元组并将其打印出来,请执行以下操作:
kafkacat -b kafka10.myorg.com:9092 -t MyTopic -o -1 -f '%s\n'
在我的终端里有这样的东西:
�ǐے�ғ�����������ǐے�ғ���������S1_153314S3_153314S4_5422973S2_5420991...
我是否可以将打印出来的负载转换成二进制格式,以便将其输入到本地代码进行调试?
我可以用 kafkacat
要从主题中获取元组并将其打印出来,请执行以下操作:
kafkacat -b kafka10.myorg.com:9092 -t MyTopic -o -1 -f '%s\n'
在我的终端里有这样的东西:
�ǐے�ғ�����������ǐے�ғ���������S1_153314S3_153314S4_5422973S2_5420991...
我是否可以将打印出来的负载转换成二进制格式,以便将其输入到本地代码进行调试?
1条答案
按热度按时间wqlqzqxt1#
您可以直接将消息作为二进制数据使用,而无需应用格式。
使用-d“”是为了避免将“\n”添加到二进制数据中。https://github.com/edenhill/kafkacat/issues/72