Kafka Server: kafka_2.11-0.9.0.1, Kafka Client:0.9.0.1 2 Kafka brokders(with 1 zookeeper node) as below: bootstrap.servers=kafka-node0:9092,kafka-node1:9092
then kill the kafka-node0 ,and when the consumer code run at: ConsumerRecords<?, ?> records = consumer.poll(100); got the messages below: 15:20:47.843 [main] DEBUG org.apache.kafka.clients.NetworkClient - Sending metadata request ClientRequest(expectResponse=true, callback=null, request=RequestSend(header={api_key=3,api_version=0,correlation_id=489,client_id=consumer-1}, body={topics=[paramsTopic]}), isInitiatedByNetworkClient, createdTimeMs=1468221647843, sendTimeMs=0) to node 1 15:20:47.847 [main] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 246 to Cluster(nodes = [Node(1, kafka-node0, 9092)], partitions = [Partition(topic = paramsTopic, partition = 3, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 6, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 0, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 1, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 7, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 2, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 8, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 9, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 5, leader = 1, replicas = [1,], isr = [1,], Partition(topic = paramsTopic, partition = 4, leader = 1, replicas = [1,], isr = [1,]]) 15:20:47.847 [main] DEBUG org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Issuing group metadata request to broker 1 I did not see any message recieved, Why? Harim Tong