如何将messagepack编码的消息从kafka接收到mongodb中

93ze6v8z 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(441)

我有一个kafka主题，其中的值是messagepack编码的。
是否有任何方法可以使用mongodbkafka连接器将本主题中的记录放入mongodb，或者记录值必须简单地存储为json？

mongodb apache-kafka apache-kafka-connect mongodb-kafka-connector msgpack

来源：https://stackoverflow.com/questions/62459021/how-to-sink-messagepack-encoded-messages-into-mongodb-from-kafka

1条答案

按热度按时间

klsxnrf11#

您需要找到或创建自己的Kafka连接 Converter ，然后将该包添加到每个connect worker的类路径，然后将其设置为键/值转换器设置，现有mongo sink连接器可以从中将消息反序列化为 Struct 以及 Schema 形成，正确处理。
json从来不是一个要求。avro和protobuf也应该工作

赞(0）回复(0）举报 2021-06-05

我来回答

如何将messagepack编码的消息从kafka接收到mongodb中

1条答案

相关问题

热门标签

最新问答