我有一个kafka主题,其中的值是messagepack编码的。是否有任何方法可以使用mongodbkafka连接器将本主题中的记录放入mongodb,或者记录值必须简单地存储为json?
klsxnrf11#
您需要找到或创建自己的Kafka连接 Converter ,然后将该包添加到每个connect worker的类路径,然后将其设置为键/值转换器设置,现有mongo sink连接器可以从中将消息反序列化为 Struct 以及 Schema 形成,正确处理。json从来不是一个要求。avro和protobuf也应该工作
Converter
Struct
Schema
1条答案
按热度按时间klsxnrf11#
您需要找到或创建自己的Kafka连接
Converter
,然后将该包添加到每个connect worker的类路径,然后将其设置为键/值转换器设置,现有mongo sink连接器可以从中将消息反序列化为Struct
以及Schema
形成,正确处理。json从来不是一个要求。avro和protobuf也应该工作