我有一个Kafka主题,其中的值是MessagePack编码的。
有没有办法使用 MongoDB Kafka 连接器将本主题中的记录下沉到 MongoDB 中,或者必须将记录值简单地存储为 JSON?
您需要查找或创建自己的 Kafka ConnectConverter
,然后将该包添加到每个 Connect 工作线程的类路径中,然后将其设置为键/值转换器设置,现有的 Mongo 接收器连接器可以从中将消息反序列化为Struct
和Schema
形式,并正确处理。
JSON从来都不是必需的。Avro 和 Protobuf 也应该工作