If you change the url the broker is available on, you need to change the public advertised hostname in the configuration of the broker, this is not a bug, there is no way the broker could know how it can be reached from the outside, and when it changes.
On Tue, Aug 23, 2016 at 10:33 AM chao (JIRA) <[email protected]> wrote: > 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) >
