Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1692

[Java New Producer] IO Thread Name Must include Client ID

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Trivial
    • Resolution: Fixed
    • Affects Version/s: 0.8.2.0
    • Fix Version/s: 0.8.2.0
    • Component/s: producer
    • Labels:

      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);
      

        Attachments

        1. KAFKA-1692.patch
          1 kB
          Ewen Cheslack-Postava

          Activity

            People

            • Assignee:
              ewencp Ewen Cheslack-Postava
              Reporter:
              Bmis13 Bhavesh Mistry
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: