Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 23 (0.107s).
Loading phrases to help you
refine your search...
enhancements to kafka-websocket - Kafka - [mail # user]
...i've been a busy little bee this week so kafka-websocket now supports keyedmessages and user-defined transforms for messages. the latter is prettyraw, improvement suggestions in the form of ...
   Author: Benjamin Black, 2014-04-16, 18:35
Re: Broker plugins - Kafka - [mail # user]
...Or introduce an app layer between the producers and kafka that does theprocessing without changes/load to the producers.On Thu, Mar 13, 2014 at 1:18 PM, Neha Narkhede wrote: ...
   Author: Benjamin Black, 2014-03-13, 20:35
[expand - 4 more] - Re: Remote Zookeeper - Kafka - [mail # user]
...If they are on different physical machines then binding to localhost/usinglocalhost as the host name is unlikely to be what you want.On Tuesday, March 11, 2014, A A  wrote: ...
   Author: Benjamin Black, 2014-03-11, 18:49
[expand - 3 more] - Re: kafka-websocket on github - Kafka - [mail # user]
...high volume query output streams will overwhelm browsers, as you'veexperienced. best practice is don't do that.On Tue, Mar 11, 2014 at 10:53 AM, Pierre Andrews wrote: ...
   Author: Benjamin Black, 2014-03-11, 17:57
[expand - 3 more] - Re: There is insufficient memory for the Java Runtime Environment to continue. - Kafka - [mail # user]
...Don't know if you figured this out, but I suspect the problem is thatbin/kafka-server-start.sh in the current 0.8.0 code has this line:export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"Which would overr...
   Author: Benjamin Black, 2014-02-02, 08:00
Re: [jira] [Commented] (KAFKA-1234) All kafka-run-class.sh to source in user config file (to set env vars like KAFKA_OPTS) - Kafka - [mail # dev]
...On CentOS the equivalent is files in /etc/sysconfig. As with /etc/default,they are per service settings exactly as you want and exactly to solve theproblem you have. There is no need to chan...
   Author: Benjamin Black, 2014-02-01, 00:22
Re: redis versus zookeeper to track consumer offsets - Kafka - [mail # user]
...ZK was designed from the start as a clustered, consistent, highly availablestore for this sort of data and it works extremely well. Redis wasn't and Idon't know anyone using Redis in product...
   Author: Benjamin Black, 2013-12-17, 19:02
Re: storing last processed offset, recovery of failed message processing etc. - Kafka - [mail # user]
...You might look at Curator http://curator.apache.org/On Mon, Dec 9, 2013 at 12:36 PM, S Ahmed  wrote:> Say am I doing this, a scenerio that I just came up with that demonstrates> #...
   Author: Benjamin Black, 2013-12-09, 20:46
Re: Trade-off between topics and partitions? - Kafka - [mail # user]
...Deja vu!IMO, what you are describing is a database problem, even though you aretalking/thinking about it as a queue problem. I'm sure you could constructsomething using Kafka (and Samza), bu...
   Author: Benjamin Black, 2013-12-06, 05:33
Re: are kafka consumer apps guaranteed to see msgs at least once? - Kafka - [mail # user]
...why not just disable autocommit and only call commit offsets() after you'veprocessed a batch? it isn't obvious to me how doing so would allow amessage to be processed zero times.On Nov 21, 2...
   Author: Benjamin Black, 2013-11-22, 01:59
Kafka (23)
Cassandra (3)
Spark (1)
mail # user (19)
mail # dev (4)
last 7 days (0)
last 30 days (0)
last 90 days (0)
last 6 months (0)
last 9 months (23)
Jun Rao (1036)
Neha Narkhede (653)
Neha Narkhede (412)
Jay Kreps (345)
Jun Rao (276)
Guozhang Wang (246)
Joe Stein (213)
Joel Koshy (206)
John Fung (95)
Joe Stein (94)
Guozhang Wang (89)
Jay Kreps (89)
Jason Rosenberg (70)
Swapnil Ghike (62)
David Arthur (61)
Sriram Subramanian (60)
None (60)
Chris Burroughs (58)
Swapnil Ghike (51)
John Fung (39)
Joel Koshy (38)
Timothy Chen (32)
Sriram Subramanian (30)
Alan D. Cabrera (24)
Gwen Shapira (24)
Benjamin Black