カフカ接続にelasticsearchコネクタ(コンフルエント)を使用しています。トピックからelasticsearchインデックスにメッセージを取得しています。キーが使用されていない場合、オフセットは _id の一部であることがわかります。オフセットとタイムスタンプに基づいて、elasticseach のメッセージを閲覧したいと考えています。
メッセージのオフセットとタイムスタンプをインデックスのフィールドとして取得することは可能ですか?
これがelasticsearchドキュメントです
{
"_index": "test-elasticsearch-sink",
"_type": "kafka-connect",
"_id": "test-elasticsearch-sink+0+0",
"_score": 1,
"_source": {
"f1": "value1"
}
}
ありがとう、ラジェッシュ