There's a definite desire to separate the controller and normal traffic. That's 
evident in the comment linked below. I don't know the exact reasons why this is 
desired behavior.

Also, I misspoke earlier. It's not just the logging. They want to separate the 
controller and normal traffic into different connections. The separated logging 
is a natural consequence of that.

https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java#L593

> On Oct 23, 2017, at 2:21 AM, pravin kumar <pk007...@gmail.com> wrote:
> 
> i have one doubt in ur answer: why should we differentiate the kafka logs
> trafiic from controller node with the normal trafiic from the same node??
> 
> 
>> On Sat, Oct 21, 2017 at 1:52 AM, Eric Azama <eazama...@gmail.com> wrote:
>> 
>> Kafka logs traffic to the Controller node separately from the normal
>> traffic to the node. In order to differentiate it subtracts the broker id
>> from 2147483647 (max int) and uses the result as the "node id" for the
>> controller.
>> 
>> On a related note, logs and metrics related to the bootstrap process seems
>> to be logged with negative integers. -1 for the first bootstrap server, -2
>> for the second and so on.
>> 
>> 
>> 
>> ---------- Forwarded message ----------
>> From: pravin kumar <pk007...@gmail.com>
>> To: users@kafka.apache.org
>> Cc:
>> Bcc:
>> Date: Fri, 20 Oct 2017 14:44:04 +0530
>> Subject: reg Kafka Node num
>> I have run a Multiple Partition and Multiple Consumer application.Then i
>> have altered the no of Partitions,
>> 
>> in log im getting
>> 
>> Using older server API v0 to send HEARTBEAT
>> {group_id=
>> altermultipartitionmulticonsumer2,group_generation_id=6,
>> member_id=C2-b7b4f485-d0c3-466b-b0e7-b3de834832e9} to node 2147483647.
>> (org.apache.kafka.clients.NetworkClient)
>> 
>> i have one node  and 3 consumers and 15 partitions.
>> 
>> my doubt is :why im getting this num node 2147483647 since i have only
>> one node
>> 

Reply via email to