Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 482 (0.047s).
Loading phrases to help you
refine your search...
Re: Created topic by 2 partitions, only can use the one partition - Kafka - [mail # user]
...Hi Jiang,Which producer client did you use? And did you specify any keys for yoursent messages?GuozhangOn Tue, Sep 30, 2014 at 10:45 AM, Jiang Jacky  wrote: ...
   Author: Guozhang Wang, 2014-10-01, 00:07
[expand - 1 more] - Re: rebalance brokers - Kafka - [mail # user]
...In 0.7 one is required to manually create partitions for existing topicswhen we add new brokers (i.e. modify the zk registration path).On Mon, Sep 29, 2014 at 9:07 PM, Guangle Fan  wrot...
   Author: Guozhang Wang, 2014-09-30, 15:41
Re: multi-node and multi-broker kafka cluster setup - Kafka - [mail # user]
...Hello,In general it is not required to have the kafka brokers installed on thesame nodes of the zk servers, and each node can host multiple kafkabrokers: you just need to make sure they do n...
   Author: Guozhang Wang, 2014-09-30, 15:35
Re: conflicted ephemeral node error - Kafka - [mail # user]
...Hi Snehalata,Did you see this log only a few times or it keep spilling in the log file?GuozhangOn Sun, Sep 28, 2014 at 11:20 PM, Snehalata Nagaje <[EMAIL PROTECTED]> wrote: ...
   Author: Guozhang Wang, 2014-09-30, 01:19
[expand - 1 more] - Re: Re: Log.scala - Kafka - [mail # user]
...At line 243:appendInfo.firstOffset = nextOffset.getIf there is a gap between two message sets, then appendInfo.offsetsMonotonicwill then catch it right?offsetsMonotonicOn Mon, Sep 29, 2014 a...
   Author: Guozhang Wang, 2014-09-30, 00:55
[expand - 3 more] - Re: Questions about Kafka 0.9 API changes - Kafka - [mail # user]
...Thanks Valentin!GuozhangOn Sun, Sep 28, 2014 at 3:49 PM, Valentin  wrote: ...
   Author: Guozhang Wang, 2014-09-30, 00:52
Re: How producer gets the acknowledgement back - Kafka - [mail # dev]
...Hi,In the new (Java) producer, you can pass in a callback function in theFuture send(ProducerRecord record, Callback callback)call, which will be triggered when the ack is received.Alternati...
   Author: Guozhang Wang, 2014-09-25, 01:06
Re: Producer errors (failed to send producer request, failed to send requests for topics) - Kafka - [mail # user]
...Kyle, the new producer will handle this exception with the specificexception type, and the callback handling function can treat itaccordingly. Could you give the new producer client a try an...
   Author: Guozhang Wang, 2014-09-25, 01:03
[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
Sort:
project
Kafka (482)
type
mail # user (277)
mail # dev (131)
issue (74)
date
last 7 days (8)
last 30 days (31)
last 90 days (126)
last 6 months (268)
last 9 months (482)
author
Jun Rao (1013)
Neha Narkhede (644)
"Neha Narkhede (412)
Jay Kreps (337)
"Jun Rao (277)
Guozhang Wang (233)
Joel Koshy (201)
Joe Stein (199)
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)