Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 475 (0.096s).
Loading phrases to help you
refine your search...
Re: Questions about Kafka 0.9 API changes - Kafka - [mail # user]
...Hello,1) The new consumer clients will be developed under a new directory. Theold consumer, including the SimpleConsumer will not be changed, though itwill be retired in the 0.9 release.2) I...
   Author: Guozhang Wang, 2014-09-22, 17:09
[expand - 1 more] - Re: How to use RPC mechanism in Kafka? - Kafka - [mail # user]
...Agree with Svante, for your use case Kafka can be used to retain yourrequest messages, but it is not proper for RPC usages.On Mon, Sep 22, 2014 at 6:06 AM, svante karlsson  wrote: ...
   Author: Guozhang Wang, 2014-09-22, 16:51
Re: Handling errors in the new (0.8.2) Java Client's Producer - Kafka - [mail # user]
...Hello Andrew,I think you would want a sync producer for your use case? You can try tocall get() on the returned metadata future of the send() call instead ofusing a callback; the pattern is ...
   Author: Guozhang Wang, 2014-09-19, 19:32
Re: zookeeper upgrade or remove zookeeper dependency - Kafka - [mail # user]
...Hi Mingtao,We are shooting to cut the 0.8.2 branch this month.GuozhangOn Thu, Sep 18, 2014 at 10:36 AM, Mingtao Zhang wrote: ...
   Author: Guozhang Wang, 2014-09-18, 18:05
Re: (info)kafka truncate data of specific topic - Kafka - [mail # dev]
...Hi Jacky,Could you elaborate a bit on your use cases, like why you want to manuallytruncate logs? Kafka provide a set of configs for data retention based ondata size and time (for example ma...
   Author: Guozhang Wang, 2014-09-16, 17:22
[expand - 1 more] - Re: Error handling in new Java Producer - Kafka - [mail # dev]
...Hi Steve,You can try to reduce the metadata.fetch.timeout.ms config value, whichwill controll how much the send() call can be blocked upon broker metadatanot available (due to broker itself ...
   Author: Guozhang Wang, 2014-09-10, 02:10
[KAFKA-1583] Kafka API Refactoring - Kafka - [issue]
...This is the next step of KAFKA-1430. Details can be found at this page:https://cwiki.apache.org/confluence/display/KAFKA/Kafka+API+Refactoring...
http://issues.apache.org/jira/browse/KAFKA-1583    Author: Guozhang Wang, 2014-09-05, 22:55
[KAFKA-1482] Transient test failures for kafka.admin.DeleteTopicTest - Kafka - [issue]
...A couple of test cases have timing related transient test failures:kafka.admin.DeleteTopicTest > testPartitionReassignmentDuringDeleteTopic FAILED    junit.framework.Assert...
http://issues.apache.org/jira/browse/KAFKA-1482    Author: Guozhang Wang, 2014-09-05, 22:53
[KAFKA-1616] Purgatory Size and Num.Delayed.Request metrics are incorrect - Kafka - [issue]
...The request purgatory used two atomic integers "watched" and "unsatisfied" to record the purgatory size ( = watched + unsatisfied) and number of delayed requests ( = unsatisfied). But due to...
http://issues.apache.org/jira/browse/KAFKA-1616    Author: Guozhang Wang, 2014-09-05, 06:25
[KAFKA-1235] Enable server to indefinitely retry on controlled shutdown - Kafka - [issue]
...Today the kafka server can exit silently if it hits an exception that is swallowed during controlled shut down or "controlled.shutdown.max.retries" has been exhausted. It is better to add an...
http://issues.apache.org/jira/browse/KAFKA-1235    Author: Guozhang Wang, 2014-09-04, 23:22
Kafka (475)
mail # user (271)
mail # dev (130)
issue (74)
last 7 days (5)
last 30 days (33)
last 90 days (128)
last 6 months (272)
last 9 months (475)
Jun Rao (1010)
Neha Narkhede (639)
"Neha Narkhede (412)
Jay Kreps (335)
"Jun Rao (277)
Guozhang Wang (229)
Joel Koshy (198)
Joe Stein (193)
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)