Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 13 (0.116s).
Loading phrases to help you
refine your search...
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
producer thread safe? - Kafka - [mail # user]
...Hi,I want to confirm is   private kafka.javaapi.producer.Producer thread safe?i.e. I can use one producer  to send data in multi threads at the same time. ...
   Author: Yonghui Zhao, 2013-04-15, 13:03
Re: Kafka log retentions - Kafka - [mail # user]
...Got it£¬thanks2013/4/2 Philip O'Toole > On Mon, Apr 1, 2013 at 8:44 PM, Yonghui Zhao > wrote:>> > A little question£¬ when old message log is deleted£¬ the start point> off...
   Author: Yonghui Zhao, 2013-04-02, 03:55
Re: Connection reset by peer - Kafka - [mail # user]
...Will do a check, I just wonder why broker need re-regiester and it failed,so broker service is stopped.2013/3/28 Jun Rao > Do you see lots of ZK session expiration in the broker too? If s...
   Author: Yonghui Zhao, 2013-03-28, 15:32
Re: commitOffsets java.lang.NullPointerException - Kafka - [mail # user]
...Done,  https://issues.apache.org/jira/browse/KAFKA-8242013/3/25 Neha Narkhede > On the Kafka JIRA - https://issues.apache.org/jira/browse/KAFKA>> Thanks,> Neha>> On Su...
   Author: Yonghui Zhao, 2013-03-25, 06:00
[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 threa...
http://issues.apache.org/jira/browse/KAFKA-824    Author: Yonghui Zhao, 2013-03-25, 05:59
Kafka (13)
mail # user (12)
issue (1)
last 7 days (0)
last 30 days (0)
last 90 days (2)
last 6 months (4)
last 9 months (13)
Jun Rao (845)
Neha Narkhede (578)
"Neha Narkhede (412)
Jay Kreps (300)
"Jun Rao (277)
Joe Stein (161)
Joel Koshy (145)
Guozhang Wang (124)
John Fung (95)
"Joe Stein (94)
"Jay Kreps (90)
"Guozhang Wang (89)
Jason Rosenberg (68)
Swapnil Ghike (62)
David Arthur (61)
Yonghui Zhao