カフカコネクトの弾性検索コネクタ - オフセットとタイムスタンプ

Question

kafka connectにelasticsearchコネクタ（コンフルエント）を使用しています。トピックからelasticsearchインデックスへのメッセージを取得しています。キーが使用されていなければ、オフセットは_idの一部であることがわかります。私はelasticseachのメッセージをオフセットとタイムスタンプに基づいてブラウズしたいと思っています。

メッセージのオフセットとタイムスタンプをインデックスのフィールドとして取得できますか？ここで

はelasticsearchドキュメント

{ "_index": "test-elasticsearch-sink", "_type": "kafka-connect", "_id": "test-elasticsearch-sink+0+0", "_score": 1, "_source": { "f1": "value1" } }

おかげで、 ラジェッシュ

Answer 1

これは現在可能ではないですが、私たちはtimestampのようにレコードのメタデータを巻き上げ許可する機能の線に沿って考えているあります、topic,partition、offsetとフィールド。

Answer 2

Single Message Transformsを使用すると、実際にオフセットやタイムスタンプなどの値を含む新しいフィールドを追加できます。 org.apache.kafka.connect.transforms.InsertFieldをご覧ください。