Если Кафка оперируется отдельной командой, ей нужно будет оповестить неопределенное количество кастомеров, что из кластера выведена/добавлена нода, а всем остальным перепушнуть конфиги
Используем классическую схему поставки логов коллектор->кафка->logstash->es и периодически ловим грабли на то что es на конце не может переварить данные, так как они конфликтуют с текущей схемой индекса.