Решаю задачу по передаче данных elastic -> kafka ->Oracle Для связки elastic->kafka используем JSON плагин https://www.elastic.co/guide/en/logstash/current/plugins-codecs-json...
А ты не хочешь для них отдельный поток сделать с фильтрацией на входе?
Схема не используется?