當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刪除。
猜您在找
druid拋出異常：javax.management.InstanceAlreadyExistsException: com.alibaba.druid:type=DruidDataSource,id=xxx
druid拋出的異常------javax.management.InstanceAlreadyExistsException引發的一系列探索
kafka--- consumer 消費消息
如何讓kafka consumer從指定的位置開始消費
kafka（四）Kafka Consumer消費者詳解
淘寶druid報錯：javax.management.InstanceNotFoundException: com.alibaba.druid:type=DruidDataSourceStat
kafka消息的分發與消費
Kafka中的消費者組（Consumer Group）
消費一下kafka的__consumer_offsets
Flink Kafka consumer的消費策略配置