[KAFKA-4078] VIP for Kafka doesn't work

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Cannot Reproduce
• Affects Version/s: 0.9.0.1
• Component/s: clients
• Assignee: Unassigned
• Reporter: chao
• Created: 23/Aug/16 08:33
• Updated: 19/Aug/17 16:04
• Resolved: 19/Aug/17 16:04

Description

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,]])