Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 17 (0.124s).
Loading phrases to help you
refine your search...
[KAFKA-824] java.lang.NullPointerException in commitOffsets - Kafka - [issue]
...Neha Narkhede"Yes, I have. Unfortunately, I never quite around to fixing it. My guess isthat it is caused due to a race condition between the rebalance thread andthe offset commit thread whe...
http://issues.apache.org/jira/browse/KAFKA-824    Author: Yonghui Zhao, 2014-06-06, 18:24
how to know kafka producer api status - Kafka - [mail # user]
...If l use java producer api in sync mode.  public void send(kafka.producer.KeyedMessage message) { /* compiledcode */ }How to know whether a send process is successful or failed?For...
   Author: Yonghui Zhao, 2014-05-16, 13:52
Re: owner info in zk is not correct - Kafka - [mail # user]
...Thanks GuoZhang.After last accident, we stop all consumers and then restart all consumersone by one then it is ok.2 brokers,  10 partitions / broker,  3 consumers, each create &nbs...
   Author: Yonghui Zhao, 2014-05-15, 23:30
high level consumer shutdown exception - Kafka - [mail # user]
...In kafka 0.8.1, when I shut down high level consumer, I found one exception.I think it is expected, right?14/04/19 21:12:47 INFO consumer.ZookeeperConsumerConnector:[1_yozhao-ubuntu-13979131...
   Author: Yonghui Zhao, 2014-04-19, 13:16
zkclient version - Kafka - [mail # user]
...HiI am trying kafka 0.8.1, and use zkclient version:                  com.101tec            zkclient...
   Author: Yonghui Zhao, 2014-04-17, 13:32
How kafka assign partition to stream - Kafka - [mail # user]
...In my environment,  I have 2 brokers and only 1 topic,  each brokers has 10partitions,so there are 20 partitions in total.I have 4 consumers in one consumer group,  each consu...
   Author: Yonghui Zhao, 2014-03-10, 17:23
Does high level consumer support setting offset - Kafka - [mail # user]
...Hi£¬In kafka 0.8, does high level consumer support setting offset?Our service reads kafka data but won't  flush the data immediately, so ifrestarted the data in memory will be lost. &nb...
   Author: Yonghui Zhao, 2014-02-27, 16:25
How to monitor consumer connection? - Kafka - [mail # user]
...Hi,In kafka 0.7.2,  we use 2 brokers and 12 consumers.I have 2 questions:1. seems if one broker is restarted then all consumers need restart toreconnect to kafka.  right?2. How to ...
   Author: Yonghui Zhao, 2013-12-13, 07:36
How to set kafka path in zk - Kafka - [mail # user]
...Hi,If I don't want to register kafka in zk root and I want to make it under anamespace, for example kafka1.If I set only one host in zk property something like10.237.0.1:2181/kafka, it  ...
   Author: Yonghui Zhao, 2013-12-05, 16:20
Re: InvalidMessageException - Kafka - [mail # user]
...Thanks ¹ú¶°£¡2013/5/30 Íõ¹ú¶° > Hi Yonghui£¬>> We see this exception too. We believe this is related to the jdk versions.> In our case, the exception only happens on heavy worklo...
   Author: Yonghui Zhao, 2013-05-30, 06:00
Kafka (17)
mail # user (16)
issue (1)
last 7 days (0)
last 30 days (0)
last 90 days (3)
last 6 months (7)
last 9 months (17)
Jun Rao (969)
Neha Narkhede (624)
"Neha Narkhede (412)
Jay Kreps (327)
"Jun Rao (277)
Guozhang Wang (203)
Joe Stein (180)
Joel Koshy (178)
John Fung (95)
"Joe Stein (94)
"Jay Kreps (90)
"Guozhang Wang (89)
Jason Rosenberg (70)
Swapnil Ghike (62)
David Arthur (61)
"Sriram Subramanian (60)
None (60)
Chris Burroughs (58)
"Swapnil Ghike (52)
"John Fung (39)
"Joel Koshy (38)
Timothy Chen (32)
Sriram Subramanian (30)
Alan D. Cabrera (24)
"Jason Rosenberg (20)
Yonghui Zhao