如何使用 MongoDB Kafka Source Connector 生成 JSON 格式的 kafka 消息？

Question

我在阅读有关 MongoDB Kafka 连接器转换器的文档时感到困惑。有人可以至少回答我的一个问题吗...

1. https://www.mongodb.com/docs/kafka-connector/v1.3/introduction/converters/#json-converter 在本文档中，有

   StringConverter

   和

   JsonConverter

   。 他们有什么区别？？我想知道它们的输入和输出类型。

2. https://www.mongodb.com/docs/kafka-connector/v1.3/introduction/data-formats/#raw-json 在这里，它说

在源或接收器连接器上指定字符串转换器时使用原始 JSON。

这是否意味着当我想将 JSON 字符串转换为 JSON 时，我应该使用 StringConverter，而不是 JsonConverter？

3. 我想做的是在 MongoDB 中创建更改事件时以 JSON 格式生成 kafka 消息。但似乎原生 MongoDB Source Connector 将有效负载作为 JSON 字符串类型提供，而不是 JSON。我怎样才能实现它？