Я использую коннектор elasticsearch (конфлюэнтный) для подключения kafka. Я получаю сообщения из темы в индекс elasticsearch. Я вижу, что смещение является частью _id, если ключ не используется. Я хочу просматривать сообщения в elasticseach на основе смещений и отметок времени.
Можно ли получить смещение и временную метку сообщения в виде полей в индексе?
Вот документ elasticsearch
{
"_index": "test-elasticsearch-sink",
"_type": "kafka-connect",
"_id": "test-elasticsearch-sink+0+0",
"_score": 1,
"_source": {
"f1": "value1"
}
}
Спасибо, Раджеш
