kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ashish K Singh (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers
Date Wed, 01 Jul 2015 01:43:05 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Ashish K Singh updated KAFKA-972:
---------------------------------
    Attachment: KAFKA-972_2015-06-30_18:42:13.patch

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

Mime
View raw message