Я пытался настроить коннектор Confluent Kafka Elasticsearch, и, похоже, все в порядке.
Единственный вопрос, на который я не могу найти ответ - как этот соединитель управляет коммитами?
Что происходит с данными после достижения параметра max.retries ?
Смещается ли откат на сторону Кафки?