Я использую Logstash для отправки данных журнала в службу Elasticsearch в AWS. Теперь у меня есть некоторая бизнес-логика, определенная в Spark Streaming, которую я хочу применить к данным журнала в режиме реального времени, поэтому я думаю об использовании Amazon SQS или Apache Kafka посередине.
Правильно ли использовать Кафку в этом сценарии?
Спасибо.