flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Thach Le <thachpor...@gmail.com>
Subject How to using Flume 1.9.0 with sink ElasticSearch 7.6.2
Date Tue, 14 Apr 2020 13:28:04 GMT
Dear all,
I have learned to deploy Hadoop 2.10.0 + Flume 19.0 + ElasticSearch 1.7.6
to demo a context:
nginx log ====> Hadoop & ElasticSearch.

I found the Flume 19.0 works with library Elastic Search 1.7.6.
Now I want to run with ElasticSearch 7.6.2 but I faced this problem:

java.lang.IllegalStateException: Received message from unsupported version:
[1.0.0] minimal compatible version is: [6.8.0]

I'm analyzing this root cause from the old library flume client (file
flume-ng-elasticsearch-sink-1.9.0.jar) sending a message with version
1.0.0. While the new version ElasticSearch 7.6.2 support message with
version 6.8.0.

Can you help me to run Flume with new version of ElasticSearch?

Thach

Mime
View raw message