Отображение темы при потоковой передаче из Kafka в Elasticsearch

Question

Когда я передаю или транслирую две и три таблицы, я могу легко отобразить в Elasticsearch, но могу ли я автоматически сопоставить темы с индексом

У меня есть потоковые данные из PostgreSQL в ES путем сопоставления вручную topic.index.map=topic1:index1,topic2:index2 и т. Д..

Могу ли я автоматически сопоставлять темы, отправленные производителем, а затем автоматически потребляемые потребителем в соединителе ES?

Answer 1

По умолчанию темы отображаются непосредственно в одноименный индекс.

Если вы хотите «лучший» контроль, вы можете использовать RegexRouter в свойстве transforms

Чтобы процитировать документы

topic.index.map

Эта опция теперь устарела.Будущая версия может удалить его полностью.Используйте преобразования одного сообщения, такие как RegexRouter, для сопоставления названий тем с именами индексов

Если вы не можете захватить одно регулярное выражение для каждой темы в соединителе, запустите несколько соединителей с другим шаблоном