TL; DR: я хочу сохранить данные в ElasticSearch, как я могу это сделать?
У меня есть zipkin, Kafka и ElasticSearch. Кафка как средство передвижения по следам. Когда я отправляю трассировку в Kafka, я получаю ее в пользовательском интерфейсе zipkin, она сохраняется в памяти. Я хочу сохранить все следы в ES 5.0 в течение некоторого времени, и когда запускается zipkin или когда я ищу следы, я хочу искать в ES или загружать трассировку из ES во время запуска zipkin.
Я запускаю zipkin, интегрированный с Kafka:
KAFKA_ZOOKEEPER=kafka1:2181,kafka2:2181 KAFKA_GROUP_ID=zipkin java -jar /opt/zipkin/bin/zipkin.jar --logging.level.zipkin=DEBUG
Вот https://github.com/openzipkin/zipkin/tree/master/zipkin-storage/elasticsearch-http:
Это вывод:
STORAGE_TYPE=elasticsearch ES_HOSTS=es5_1:9200 java -jar /opt/zipkin/bin/zipkin-dependencies.jar
17/04/13 17:16:25 INFO ElasticsearchDependenciesJob: Processing spans from zipkin-2017-04-13/span
17/04/13 17:16:25 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
17/04/13 17:16:28 INFO ElasticsearchDependenciesJob: Saving dependency links to zipkin-2017-04-13/dependencylink
17/04/13 17:16:28 INFO ElasticsearchDependenciesJob: Done
Но в ES в индексе zipkin нет данных.