MongoDB シンク コネクタ (コネクタ)で Apache Kafka Connect を使用しようとしました
Avro 形式を使用すると、1 つの問題を除いて機能しましたが、コネクタが新しい Mongo レコードの _id に record.kafkaOffset() を使用するため、1 つのパーティションでトピックを作成する必要がありました (したがって、複数のパーティションでは、異なるレコードに対して同じ ID を取得します)。記録）。
どうすれば修正できますか？
Jsonでテストしたいので、そのための新しいトピックを作成しました。そして、コンバーターの構成を JsonConverter に変更しました。実行すると、次のエラーが表示されます。
java.lang.ClassCastException: org.apache.kafka.connect.mongodb.MongodbSinkTask.put(MongodbSinkTask.java:106) で java.util.HashMap を org.apache.kafka.connect.data.Struct にキャストできません。 org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:176) の org.apache.kafka.connect.runtime. 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 で動作しますか?