我是ELK堆栈的新手，我只是想知道是否可以使用Kafka将我们的日志文件发送到Elasticsearch。但我需要Logstash的工作（解析使用滤镜一样日志神交 ）在卡夫卡要做为好。这整个事情可能吗？基本上，我想做的是用Kafka替换Filebeats和Logstash的组合，我想知道是否可行。
谢谢 ：）
注意：我想做的是在Kafka中发送和解析日志。我知道可以使用Elasticsearch连接器将日志传送到Elasticsearch，但是我要问的是，使用Kafka是否可以解析数据（Logstash的工作）。