client/metadata fetching metadata for all topics from broker 192.168.35.23:32001
client/metadata fetching metadata for all topics from broker 192.168.35.23:32001
Connected to broker at 192.168.35.23:32001 (unregistered)
Connected to broker at 192.168.35.23:32001 (unregistered)
client/brokers registered new broker #22 at 192.168.35.23:32002
client/brokers registered new broker #21 at 192.168.35.23:32001
client/brokers registered new broker #23 at 192.168.35.23:32003
Successfully initialized new client
client/brokers registered new broker #22 at 192.168.35.23:32002
client/brokers registered new broker #21 at 192.168.35.23:32001
client/brokers registered new broker #23 at 192.168.35.23:32003
Successfully initialized new client
Connected to broker at 192.168.35.23:32003 (registered as #23)
Connected to broker at 192.168.35.23:32001 (registered as #21)
Connected to broker at 192.168.35.23:32002 (registered as #22)
consumer/broker/23 added subscription to test/0
consumer/broker/21 added subscription to test/1
consumer/broker/22 added subscription to test/2
message

test
test
test1
Connected to broker at 192.168.35.23:32003 (registered as #23)
Connected to broker at 192.168.35.23:32001 (registered as #21)
Connected to broker at 192.168.35.23:32002 (registered as #22)
producer/broker/23 starting up
producer/broker/23 state change to [open] on test/0
test1
client/metadata fetching metadata for all topics from broker 192.168.35.23:32001
consumer/broker/21 disconnecting due to error processing FetchRequest: EOF
Closed connection to broker 192.168.35.23:32001
kafka: error while consuming test/1: EOF
consumer/test/1 finding new broker
client/metadata fetching metadata for [test] from broker 192.168.35.23:32001
client/metadata got error from broker while fetching metadata: EOF
Closed connection to broker 192.168.35.23:32001
client/metadata fetching metadata for [test] from broker 192.168.35.23:32001
Failed to connect to broker 192.168.35.23:32001: dial tcp 192.168.35.23:32001: getsockopt: connection refused
client/metadata got error from broker while fetching metadata: dial tcp 192.168.35.23:32001: getsockopt: connection refused
client/metadata fetching metadata for [test] from broker 192.168.35.23:32001
Failed to connect to broker 192.168.35.23:32001: dial tcp 192.168.35.23:32001: getsockopt: connection refused
client/metadata got error from broker while fetching metadata: dial tcp 192.168.35.23:32001: getsockopt: connection refused
client/metadata fetching metadata for [test] from broker 192.168.35.23:32003
consumer/broker/21 added subscription to test/1
Failed to connect to broker 192.168.35.23:32001: dial tcp 192.168.35.23:32001: getsockopt: connection refused
consumer/broker/21 disconnecting due to error processing FetchRequest: dial tcp 192.168.35.23:32001: getsockopt: connection refused
kafka: error while consuming test/1: dial tcp 192.168.35.23:32001: getsockopt: connection refused
consumer/test/1 finding new broker
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
consumer/broker/21 added subscription to test/1
Failed to connect to broker 192.168.35.23:32001: dial tcp 192.168.35.23:32001: getsockopt: connection refused
consumer/broker/21 disconnecting due to error processing FetchRequest: dial tcp 192.168.35.23:32001: getsockopt: connection refused
kafka: error while consuming test/1: dial tcp 192.168.35.23:32001: getsockopt: connection refused
consumer/test/1 finding new broker
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata found some partitions to be leaderless
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata found some partitions to be leaderless
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
kafka: error while consuming test/1: kafka server: In the middle of a leadership election, there is currently no leader for this partition and hence it is unavailable for writes.
consumer/test/1 finding new broker
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32001
Failed to connect to broker 192.168.35.23:32001: dial tcp 192.168.35.23:32001: getsockopt: connection refused
client/metadata got error from broker while fetching metadata: dial tcp 192.168.35.23:32001: getsockopt: connection refused
client/brokers deregistered broker #21 at 192.168.35.23:32001
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32003
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
kafka: error while consuming test/1: kafka server: In the middle of a leadership election, there is currently no leader for this partition and hence it is unavailable for writes.
consumer/test/1 finding new broker
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32003
client/metadata found some partitions to be leaderless
kafka: error while consuming test/1: kafka server: In the middle of a leadership election, there is currently no leader for this partition and hence it is unavailable for writes.
client/metadata fetching metadata for all topics from broker 192.168.35.23:32003
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (1 attempts remaining)
client/metadata fetching metadata for all topics from broker 192.168.35.23:32003
client/metadata found some partitions to be leaderless
consumer/test/1 finding new broker
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (3 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/metadata found some partitions to be leaderless
client/metadata retrying after 250ms... (2 attempts remaining)
client/metadata fetching metadata for [test] from broker 192.168.35.23:32002
client/brokers registered new broker #21 at 192.168.35.23:32001
consumer/broker/21 added subscription to test/1
Connected to broker at 192.168.35.23:32001 (registered as #21)
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002
test1
Closed connection to broker 192.168.35.23:32001
ERROR: kafka.go:400: test is not connected: EOF
test2client/metadata fetching metadata for all topics from broker 192.168.35.23:32002

Connected to broker at 192.168.35.23:32001 (registered as #21)
producer/broker/21 starting up
producer/broker/21 state change to [open] on test/1
test2
test3
producer/broker/22 starting up
producer/broker/22 state change to [open] on test/2
test3
client/metadata fetching metadata for all topics from broker 192.168.35.23:32002