Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 43 (0.162s).
Loading phrases to help you
refine your search...
Re: custom kafka consumer - strangeness - Kafka - [mail # user]
...If you look at the example simple consumer:https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+ExampleYou'll see:  if (currentOffset < readOffset) { &nbs...
   Author: Chris Curtin, 2014-01-09, 21:14
Re: Special Bay Area HUG: Tajo and Samza - Kafka - [mail # user]
...Hi Jay,Do they record these meetups?Thanks,ChrisOn Thu, Oct 17, 2013 at 5:03 PM, Jay Kreps  wrote:> FYI.>> ---------- Forwarded message ----------> From: Jakob Homan > Da...
   Author: Chris Curtin, 2013-10-18, 13:23
[KAFKA-966] Allow high level consumer to 'nak' a message and force Kafka to close the KafkaStream without losing that message - Kafka - [issue]
...Enhancement request.The high level consumer is very close to handling a lot of situations a 'typical' client would need. Except for when the message received from Kafka is valid, but...
http://issues.apache.org/jira/browse/KAFKA-966    Author: Chris Curtin, 2013-10-05, 02:11
[KAFKA-637] Separate log4j environment variable from KAFKA_OPTS in kafka-run-class.sh - Kafka - [issue]
...The kafka-run-class.sh script has an environment variable for 'KAFKA_OPTS' which defines the log4j configuration file with other system variables.By moving the log4j settings into th...
http://issues.apache.org/jira/browse/KAFKA-637    Author: Chris Curtin, 2013-07-12, 00:34
Re: High Level Consumer error handling and clean exit - Kafka - [mail # user]
...Thanks Ian.Is your consumer multi-threaded? If so can you share how you coordinatedeach of the threads so you knew it was 'okay' to commit across all thethreads? I'm stuck on how to do this ...
   Author: Chris Curtin, 2013-07-10, 11:14
Re: one consumerConnector or many? - Kafka - [mail # user]
...That's a good question about # of sockets when a single consumer isconnecting. I'll let someone from LinkedIn comment if each consumer has asocket per topic/partition or if it is per Broker,...
   Author: Chris Curtin, 2013-05-29, 14:53
Re: Partitioning and scale - Kafka - [mail # user]
...Hi Tim,On Wed, May 22, 2013 at 3:25 PM, Timothy Chen  wrote:> Hi,>> I'm currently trying to understand how Kafka (0.8) can scale with our usage> pattern and how to setup the...
   Author: Chris Curtin, 2013-05-22, 19:37
Re: Is there a limitation on the number of simultaneous consumer connections to the same topic - Kafka - [mail # user]
...Yes. However be aware that starting and stopping processes will cause arebalance of the consumers, so your code may find itself receiving eventsfrom a different partition suddenly (so don't ...
   Author: Chris Curtin, 2013-05-13, 13:10
Re: exception report - Kafka - [mail # user]
...Hmm, that looks a lot like the lost+found directory on a Linux file system.Is your Kafka data directory a mount point that has a lost and founddirectory?On Thu, May 9, 2013 at 12:10 PM, Neha...
   Author: Chris Curtin, 2013-05-09, 16:32
Re: a few questions from high level consumer documentation. - Kafka - [mail # user]
...On Thu, May 9, 2013 at 12:36 AM, Rob Withers  wrote:>>> > -----Original Message-----> > From: Chris Curtin [mailto:[EMAIL PROTECTED]]>> > > 1 When you say ...
   Author: Chris Curtin, 2013-05-09, 12:28
Kafka (43)
Hadoop (14)
MapReduce (1)
mail # user (34)
issue (8)
mail # dev (1)
last 7 days (0)
last 30 days (0)
last 90 days (0)
last 6 months (0)
last 9 months (43)
Jun Rao (969)
Neha Narkhede (624)
"Neha Narkhede (412)
Jay Kreps (327)
"Jun Rao (277)
Guozhang Wang (201)
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)
Chris Curtin