[
https://issues.apache.org/jira/browse/KAFKA-4078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar resolved KAFKA-4078.
------------------------------
Resolution: Cannot Reproduce
Pl reopen if you think the issue still exists
> 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
>
> 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.4.14#64029)