Я использую logstash для передачи данных из elasticsearch в kafka окончательно.
logstash также является общей структурой для приема преобразований и хранения данных, которая предлагает различные возможности ввода и вывода.плагины, включая elasticsearch input и kafka output.
Кроме того, плагины elasticsearch input также предоставляют механизм планирования, который очень удобен для приема дополнительных данных.