[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14609739#comment-14609739 ]
Ashish K Singh commented on KAFKA-972: -------------------------------------- Updated reviewboard https://reviews.apache.org/r/36030/ against branch trunk > MetadataRequest returns stale list of brokers > --------------------------------------------- > > Key: KAFKA-972 > URL: https://issues.apache.org/jira/browse/KAFKA-972 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8.0 > Reporter: Vinicius Carvalho > Assignee: Ashish K Singh > Attachments: BrokerMetadataTest.scala, KAFKA-972.patch, > KAFKA-972_2015-06-30_18:42:13.patch, KAFKA-972_2015-07-01_01:36:56.patch > > > When we issue an metadatarequest towards the cluster, the list of brokers is > stale. I mean, even when a broker is down, it's returned back to the client. > The following are examples of two invocations one with both brokers online > and the second with a broker down: > { > "brokers": [ > { > "nodeId": 0, > "host": "10.139.245.106", > "port": 9092, > "byteLength": 24 > }, > { > "nodeId": 1, > "host": "localhost", > "port": 9093, > "byteLength": 19 > } > ], > "topicMetadata": [ > { > "topicErrorCode": 0, > "topicName": "foozbar", > "partitions": [ > { > "replicas": [ > 0 > ], > "isr": [ > 0 > ], > "partitionErrorCode": 0, > "partitionId": 0, > "leader": 0, > "byteLength": 26 > }, > { > "replicas": [ > 1 > ], > "isr": [ > 1 > ], > "partitionErrorCode": 0, > "partitionId": 1, > "leader": 1, > "byteLength": 26 > }, > { > "replicas": [ > 0 > ], > "isr": [ > 0 > ], > "partitionErrorCode": 0, > "partitionId": 2, > "leader": 0, > "byteLength": 26 > }, > { > "replicas": [ > 1 > ], > "isr": [ > 1 > ], > "partitionErrorCode": 0, > "partitionId": 3, > "leader": 1, > "byteLength": 26 > }, > { > "replicas": [ > 0 > ], > "isr": [ > 0 > ], > "partitionErrorCode": 0, > "partitionId": 4, > "leader": 0, > "byteLength": 26 > } > ], > "byteLength": 145 > } > ], > "responseSize": 200, > "correlationId": -1000 > } > { > "brokers": [ > { > "nodeId": 0, > "host": "10.139.245.106", > "port": 9092, > "byteLength": 24 > }, > { > "nodeId": 1, > "host": "localhost", > "port": 9093, > "byteLength": 19 > } > ], > "topicMetadata": [ > { > "topicErrorCode": 0, > "topicName": "foozbar", > "partitions": [ > { > "replicas": [ > 0 > ], > "isr": [], > "partitionErrorCode": 5, > "partitionId": 0, > "leader": -1, > "byteLength": 22 > }, > { > "replicas": [ > 1 > ], > "isr": [ > 1 > ], > "partitionErrorCode": 0, > "partitionId": 1, > "leader": 1, > "byteLength": 26 > }, > { > "replicas": [ > 0 > ], > "isr": [], > "partitionErrorCode": 5, > "partitionId": 2, > "leader": -1, > "byteLength": 22 > }, > { > "replicas": [ > 1 > ], > "isr": [ > 1 > ], > "partitionErrorCode": 0, > "partitionId": 3, > "leader": 1, > "byteLength": 26 > }, > { > "replicas": [ > 0 > ], > "isr": [], > "partitionErrorCode": 5, > "partitionId": 4, > "leader": -1, > "byteLength": 22 > } > ], > "byteLength": 133 > } > ], > "responseSize": 188, > "correlationId": -1000 > } -- This message was sent by Atlassian JIRA (v6.3.4#6332)