我可以使用kafkacat从主题中获取元组并将其打印出来:
kafkacat -b kafka10.myorg.com:9092 -t MyTopic -o -1 -f '%s\n'在我的终端里,我得到了类似这样的东西:
�ǐے�ғ�����������ǐے�ғ���������S1_153314S3_153314S4_5422973S2_5420991...是否可以将打印输出的有效负载转换为二进制格式,以便将其提供给本地代码进行调试?
发布于 2018-09-27 02:19:23
您可以直接将消息作为二进制数据使用,而无需应用格式设置。
kafkacat -b kafka10-staging.salesforceiq.com:9092 -t MyTopic -o -1 -D "" > out.file-D "“的用法是为了避免将"\n”添加到二进制数据。https://github.com/edenhill/kafkacat/issues/72
https://stackoverflow.com/questions/51639570
复制相似问题