Вставляет ли коннектор раковины kafka запись, если преобразование возвращает NULL? - PullRequest
Новая
       5

Вставляет ли коннектор раковины kafka запись, если преобразование возвращает NULL?

0 голосов
/ 02 апреля 2020

У меня есть разъем мойки kafka (asticsearch), и я пишу пользовательский SMT. Мне интересно, что произойдет, если SMT вернет запись NULL. Что бы сделал разъем? Собирается ли что-то вставить NULL в мой индекс упругого поиска? Или он вообще не вставит?

1 Ответ

1 голос
/ 02 апреля 2020

Вы можете контролировать, как это обрабатывается, используя опцию конфигурации behavior.on.null.values.

  • ignore - сообщение игнорируется
  • delete - удаляется запись Elasticsearch с соответствующим ключом
  • fail - соединитель останавливается.

Ссылка: do c page

...