[WARN ][org.apache.kafka.common.utils.AppInfoParser] Error registering AppInfo mbean
javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=test-0
logstash input 添加多個kafka會出現這個報錯。是因為clientid唯一。
換了N個版本kafka和logstash 網上也找不到解決方法 記錄一下解決方法 希望后面的同學們少走點彎路
解決方法：
需要在logstash添加不同的client_id 配置文件如下
input {
kafka {
bootstrap_servers => "192.168.1.11:9092,192.168.1.12:9092,192.168.1.13:9092"
client_id => "test1"
topics => ["test1"]
type => "test1"
codec => 'json'
}
kafka {
bootstrap_servers => "192.168.1.11:9092,192.168.1.12:9092,192.168.1.13:9092"
client_id => "test2"
topics => ["test2"]
type => "test2"
codec => 'json'
}
}