我试图通过logstash版本将kafka的数据索引到elasticsearch:
日志存储:6.2.4
ElasticSearch:6.2.4
Kafka:0.10
avro:1.8.2版本
问题是logstash正确地读取了avro模式(至少我是这么认为的),但是每次执行我都会以不同的顺序看到它们,主要的问题是一些字段仍然是空的,其余的字段相互获取数据,因此elasticsearch中的文档不可靠和正确
ps:我检查了一些avro记录,我转换了它们,我确定问题不是来自它们,而是在logstash级别
暂无答案!
目前还没有任何答案,快来回答吧!