Description
Please add client id so people who are looking at Jconsole or Profile tool can see Thread by client id since single JVM can have multiple producer instance.
org.apache.kafka.clients.producer.KafkaProducer
String ioThreadName = "kafka-producer-network-thread"; if(clientId != null){ ioThreadName = ioThreadName + " | "+clientId; } this.ioThread = new KafkaThread(ioThreadName, this.sender, true);