我尝试将 Apache Kafka Connect 与 MongoDB 接收器连接器（连接器）一起使用
当我使用 Avro 格式时，除了一个问题外，它都可以工作，我必须用一个分区创建主题，因为连接器使用 record.kafkaOffset() 作为新 Mongo 记录的 _id（所以对于多个分区，我得到不同的相同 id记录）。
我该如何解决？
我想用 Json 测试它，所以我为此创建了一个新主题。并将转换器配置更改为 JsonConverter。当我运行它时，我收到以下错误：
java.lang.ClassCastException：java.util.HashMap 无法在 org.apache.kafka.connect.mongodb.MongodbSinkTask.put(MongodbSinkTask.java:106) 处转换为 org.apache.kafka.connect.data.Struct。 org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:176) 在 org.apache.kafka.connect.runtime 的 apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:280)。 WorkerSinkTaskThread.iteration(WorkerSinkTaskThread.java:90) 在 org.apache.kafka.connect.runtime.WorkerSinkTaskThread.execute(WorkerSinkTaskThread.java:58) 在 org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java: 82)
此连接器是否适用于 Json？