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

93ze6v8z  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(420)

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

klsxnrf1

klsxnrf11#

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

相关问题