Я использую kafka-connect -asticsearch с пользовательским конвертером, который расширяет стандарт JsonConverter.
У меня более 250 тем с различными типами событий, поэтому я рад, что Кафка-connect автоматически создает для меня индексы вasticsearch.
Однако я бы хотел отключить все анализаторы, кроме keyword -analyser (здесь не нужен полнотекстовый поиск).
Как я могу это сделать? Как и где я могу манипулировать сопоставлениями индексов ?
В моем настраиваемом преобразователе я определяю схему для своей полезной нагрузки, преобразую еев схему, специфичную для kafka-connect, а затем вернуть new SchemaAndValue(connectSchema, connectValue) object.
Я полагаю, что для подключения mappings используется схема, специфичная для connect, это правда?