如何将 MessagePack 编码的消息从 Kafka 汇入 MongoDB 中



我有一个Kafka主题,其中的值是MessagePack编码的。

有没有办法使用 MongoDB Kafka 连接器将本主题中的记录下沉到 MongoDB 中,或者必须将记录值简单地存储为 JSON?

您需要查找或创建自己的 Kafka ConnectConverter,然后将该包添加到每个 Connect 工作线程的类路径中,然后将其设置为键/值转换器设置,现有的 Mongo 接收器连接器可以从中将消息反序列化为StructSchema形式,并正确处理。

JSON从来都不是必需的。Avro 和 Protobuf 也应该工作

相关内容

  • 没有找到相关文章

最新更新