当input里面有多个kafka输入源时，client_id => "logstash-1-1"，必须添加且需要不同，
否则会报错javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=logstash-0。
参考连接：https://www.cnblogs.com/swordfall/p/8860941.html
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。
猜您在找
kafka javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=consumer-1
druid抛出异常：javax.management.InstanceAlreadyExistsException: com.alibaba.druid:type=DruidDataSource,id=xxx
kafka--- consumer 消费消息
kafka 0.8.2 消息消费者 consumer
Unable to register MBean [HikariDataSource (HikariPool-0)] with key 'dataSou rce'; nested exception is javax.management.InstanceAlreadyExistsException: com.z axxer.hikari:name=dataSource,type=HikariDa
Kafka(三) 消费者Consumer
druid抛出的异常------javax.management.InstanceAlreadyExistsException引发的一系列探索
logstash 使用kafka范例
logstash-kafka
配置logstash消费kafka多个topic,分别生成索引