[ 
https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14606755#comment-14606755
 ] 

Ashish K Singh commented on KAFKA-972:
--------------------------------------

Created 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
>
>
> 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)

Reply via email to