SpringBoot写入ES（采用Kafka+logstash+ES）方式

兄弟们兄弟们。我又来了。
之前Java程序直接写入ES。 不知道有时候网络不好。还是啥情况。
我这个写入就超时了。 然后这条消息就会丢失。 系统也嗷嗷报错。针对于这个情况。
修改了一下 写入ES的方式。
程序将消息放入-> Kafka -> logstash进行消费后输出至 -> ES中。
好了。废话不多说。老样子。大象装冰箱一共分3步
步骤1、Java程序集成kafka-》用的springBoot
maven-加入jar包

org.springframework.kafka
spring-kafka

spring配置文件。增加配置
spring:
kafka:
bootstrap-servers: kafka地址
producer:
# 发生错误后，消息重发的次数。
retries: 0

SpringBoot写入ES（采用Kafka+logstash+ES）方式最先出现在Python成神之路。