chao created KAFKA-4078:
---------------------------
Summary: VIP for Kafka doesn't work
Key: KAFKA-4078
URL: https://issues.apache.org/jira/browse/KAFKA-4078
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 0.9.0.1
Reporter: chao
Priority: Blocker
We create VIP for chao007kfk002.chao007.com, 9092 ,chao007kfk003.chao007.com,
9092 ,chao007kfk001.chao007.com, 9092
But we found that Kafka client API has some issues , client send metadata
update will return three brokers , so it will create three connections for 001
002 003
When we change VIP to chao008kfk002.chao008.com, 9092
,chao008kfk003.chao008.com, 9092 ,chao008kfk001.chao008.com, 9092
it still produce data to 007
The following is log information
sasl.kerberos.ticket.renew.window.factor = 0.8
bootstrap.servers = [kfk.chao.com:9092]
client.id =
2016-08-23 07:00:48,451:DEBUG kafka-producer-network-thread | producer-1
(NetworkClient.java:623) - Initialize connection to node -1 for sending
metadata request
2016-08-23 07:00:48,452:DEBUG kafka-producer-network-thread | producer-1
(NetworkClient.java:487) - Initiating connection to node -1 at
kfk.chao.com:9092.
2016-08-23 07:00:48,463:DEBUG kafka-producer-network-thread | producer-1
(Metrics.java:201) - Added sensor with name node--1.bytes-sent
2016-08-23 07:00:48,489:DEBUG kafka-producer-network-thread | producer-1
(NetworkClient.java:619) - Sending metadata request
ClientRequest(expectResponse=true, callback=null,
request=RequestSend(header={api_key=3,api_version=0,correlation_id=0,client_id=producer-1},
body={topics=[chao_vip]}), isInitiatedByNetworkClient,
createdTimeMs=1471935648465, sendTimeMs=0) to node -1
2016-08-23 07:00:48,512:DEBUG kafka-producer-network-thread | producer-1
(Metadata.java:172) - Updated cluster metadata version 2 to Cluster(nodes =
[Node(1, chao007kfk002.chao007.com, 9092), Node(2, chao007kfk003.chao007.com,
9092), Node(0, chao007kfk001.chao007.com, 9092)], partitions = [Partition(topic
= chao_vip, partition = 0, leader = 0, replicas = [0,], isr = [0,],
Partition(topic = chao_vip, partition = 3, leader = 0, replicas = [0,], isr =
[0,], Partition(topic = chao_vip, partition = 2, leader = 2, replicas = [2,],
isr = [2,], Partition(topic = chao_vip, partition = 1, leader = 1, replicas =
[1,], isr = [1,], Partition(topic = chao_vip, partition = 4, leader = 1,
replicas = [1,], isr = [1,]])
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
