Re: Kafka broker startup issue

of Kafka running > against the same ZK broker. Do you have any other versions running? Or is > it possible this is a shared ZK cluster and you're not using a namespace > within ZK for each cluster? > > -Ewen > > On Mon, May 22, 2017 at 12:33 AM, dhiraj prajapati > wrote: &

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019536#comment-16019536 ] dhiraj prajapati edited comment on KAFKA-4477 at 5/22/17 1:4

[jira] [Commented] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting

[ https://issues.apache.org/jira/browse/KAFKA-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019542#comment-16019542 ] dhiraj prajapati commented on KAFKA-5153: - Hi all, We have a 3-node cluste

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019536#comment-16019536 ] dhiraj prajapati edited comment on KAFKA-4477 at 5/22/17 12:4

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019536#comment-16019536 ] dhiraj prajapati commented on KAFKA-4477: - Hi all, We have a 3-node cluste

Kafka broker startup issue

Hi, I am getting the below exception while starting kafka broker 0.9.0.1: kafka.common.KafkaException: Version 2 is invalid for UpdateMetadataRequest. Valid versions are 0 or 1. at kafka.api.UpdateMetadataRequest$.readFrom(UpdateMetadataRequest.scala:58) at kafka.api.RequestKeys$$anonfun$7

Commitlog path while Upgrading kafka server from 0.9 to 0.10.2.0

Hi, I want to do a rolling upgrade of kafka server from 0.9 to 0.10.2.0. Should I keep path of the commit logs the same? what is the impact of keeping the path same/different? Thanks in advance.

Frequent UNKNOWN_MEMBER_ID errors in kafka consumer

Hi, I have a consumer which implements new consumer api (0.9.0.1). I see below errors quite frequently in the consumer application logs: ERROR [pool-4-thread-5] - o.a.k.c.c.i.ConsumerCoordinator - Error UNKNOWN_MEMBER_ID occurred while committing offsets for group audit.consumer.group Can you ple