Can not consume when a broker shutdown.

2016-07-11 Thread tong...@csbucn.com
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:

FW: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 3000 ms

2016-07-04 Thread tong...@csbucn.com
And this error message comes from Metadata.awaitUpdate() method. 发件人: tong...@csbucn.com 发送时间: 2016-07-05 10:39 收件人: users 主题: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 3000 ms Hi, I have 2 Kafka nodes and 1 zookeeper node. When I use kill -9 to shutdown

org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 3000 ms

2016-07-04 Thread tong...@csbucn.com
Hi, I have 2 Kafka nodes and 1 zookeeper node. When I use kill -9 to shutdown the kafk-node1,I got the error message from the producer when sending messages: org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 3000 ms The kafka client version is: 0.9.0.1, producer c

Producer failed to send the message to the backup kafka broker

2016-07-03 Thread tong...@csbucn.com
Hi, I have 2 kafka nodes(node0--xx.host.com:9092,node1--localhost:9093) and 1 zookeeper node,and the producer configuration is below: bootstrap.servers=xx.host.com:9092,localhost:9093 it's works fine when the 2 kafka nodes are running. But when I shutdown the node0,and I got the error logs belo

Kafka forum register

2016-07-01 Thread tong...@csbucn.com
Hello, How can I register in Kafka forum? 童树山 中嘉仁和科技(北京)有限公司 北京市朝阳区东三环北路3号幸福大厦B座813室 邮编 100027 Room 813, Block B, Lucky Tower, 3 Dongsanhuan Beilu, Chaoyang District, Beijing 100027, China Tel: 010-64661846 Fax: 010-64661840 Mobile: 13818663262 E-mail:tong...@csbucn.com 发件人: tong

Kafka forum register

2016-06-01 Thread tong...@csbucn.com
Hello, My project is using kafka ,and I want register a user in the forum,what can I do ? Tong SS