Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 59 (0.166s).
Loading phrases to help you
refine your search...
RDD operation examples with data? - Spark - [mail # user]
...Hi,I'm learning Spark and I am confused about when to use the many differentoperations on RDDs. Does anyone have any examples which show example inputsand resulting outputs for the various R...
   Author: Chris Curtin, 2014-07-31, 20:00
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
Re: chaining (the output of) jobs/ reducers - Hadoop - [mail # user]
...If you want to stay in Java look at Cascading. Pig is also helpful. I think there are other (Spring integration maybe?) but I'm not familiar with them enough to make a recommendation.  ...
   Author: Chris Curtin, 2013-09-12, 13:39
[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
[expand - 4 more] - 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
[expand - 1 more] - 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
Kafka (43)
Hadoop (14)
MapReduce (1)
Spark (1)
mail # user (50)
issue (8)
mail # dev (1)
last 7 days (0)
last 30 days (0)
last 90 days (1)
last 6 months (1)
last 9 months (59)
Ted Yu (1699)
Harsh J (1296)
Todd Lipcon (995)
Stack (978)
Jun Rao (969)
Jonathan Ellis (844)
Andrew Purtell (816)
Jean-Daniel Cryans (752)
Yusaku Sako (718)
stack (714)
Jarek Jarcec Cecho (703)
Eric Newton (688)
Jonathan Hsieh (673)
Roman Shaposhnik (663)
Namit Jain (649)
Hitesh Shah (627)
Owen O'Malley (625)
Steve Loughran (624)
Siddharth Seth (614)
Josh Elser (557)
Brock Noland (549)
Eli Collins (545)
Neha Narkhede (545)
Arun C Murthy (543)
Doug Cutting (533)
Chris Curtin