Kafkacat如何重新发布维护密钥的二进制消息
Kafkacat如何重新发布维护密钥的二进制消息
提问于 2021-02-23 17:47:34
我一直试图使用kafkacat在主题中找到一条消息并将其发布回主题中。我们使用protobuf，因此消息值应该以字节为单位(键可以是不同的，例如字符串或字节)。但是，我无法发布可以正确反序列化的消息。
我怎么能用kafkacat做这件事？我也愿意使用其他推荐的工具来做这件事。
示例尝试：
kafkacat -b <broker> -t <topic> -o -10 -e -c 1 -C -K: > test2.txtcat test2.txt | kafkacat -b <broker> -t <topic> -P -K:test2.txt显示：
21aa7e2f-41a1-4972-9108-3057627d53f0:
Y/<protobuf.class.path>i
$21aa7e2f-41a1-4972-9108-3057627d53f0A
DIABETEBG_METERBG300"BG300*QP3687WK02000012????但是，当我使用相同的kafkacat使用者命令来获得结果时，我只得到最后一行：
DIABETEBG_METERBG300"BG300*QP3687WK02000012????我认为问题在于，消费输出行(可能是有效负载的一部分？)制片人把每一条线都当作一条新信息。
回答 1
Stack Overflow用户
回答已采纳
发布于 2021-02-23 19:57:05
生产者正在将每一行视为新消息
是这样的。
如果您有一个二进制文件，我建议为此编写代码，因为kafkacat将UTF8编码的字符串作为输入。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/66338402
复制相关文章
相似问题
腾讯云开发者
