| clear query|facets|time |
Search criteria: .
Results from 41 to 50 from
59 (0.229s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Questions on consumerConnector.createMessageStreams() - Kafka - [mail # user]
|
|
...Jun, Thanks. Could this be clearly documented in the ScalaDocs and other docs? It would be very helpful. If we use a timeout, then there should be no problems with mu...
|
|
|
Author: Evan Chan,
2012-01-06, 17:55
|
|
|
Questions on consumerConnector.createMessageStreams() - Kafka - [mail # user]
|
|
...I have to pass in a Map from the topic -> #streams, according to the scaladoc at http://incubator.apache.org/kafka/api-docs/0.6/. Is this the same or different than the # of partitions? &...
|
|
|
Author: Evan Chan,
2012-01-06, 08:05
|
|
|
Re: Kafak-rb gem - Kafka - [mail # user]
|
|
...I'd be very interested in a kafka-rb gem that supports ZK. We're writing some Scala code that could have been Ruby. On Wed, Jan 4, 2012 at 10:26 AM, Dave Fayram wrot...
|
|
|
Author: Evan Chan,
2012-01-04, 21:39
|
|
|
Re: Exactly once semantics - Kafka - [mail # user]
|
|
...What you mean is that we need to modify (have our own modified copy of) the high level consumer (specifically the ConsumerConnector) so that instead of automatically calling commitOffset(), ...
|
|
|
Author: Evan Chan,
2011-12-08, 20:44
|
|
|
Re: Timestamps - Kafka - [mail # user]
|
|
...Is there a setting that controls the log segment size? Better yet, is there a way to tell the broker (maybe from the consumer), look I want you to start a new log segment? thx, E...
|
|
|
Author: Evan Chan,
2011-12-07, 17:59
|
|
|
Re: Kafka and Binary Data - Kafka - [mail # user]
|
|
...A couple quick questions: 1) What prevents one from changing the V type in the Producer API to any arbitrary type I want, such as String, or my own Thrift struct, for example? (And I s...
|
|
|
Author: Evan Chan,
2011-12-01, 21:11
|
|
|
Re: guide to contributing kafka clients - Kafka - [mail # user]
|
|
...I would like to second Tim's suggestion. For example, this would possibly allow a Scala client that supports 2.9.x, while keeping the core Kafka code on 2.8.x. -Evan On Tue...
|
|
|
Author: Evan Chan,
2011-11-29, 22:02
|
|
|
Re: the cleaner and log segments - Kafka - [mail # user]
|
|
...Jun, How do offsets keep increasing? Eventually they have to rollover back to 0, right? What happens if Kafka runs for months, eventually the offset rolls back, righ...
|
|
|
Author: Evan Chan,
2011-11-18, 17:40
|
|
|
Re: We're live! - Kafka - [mail # user]
|
|
...Taylor, Just out of curiosity, do you guys have to deal with at-least-once message processing? If so, I'd be curious how you handle all the corner cases with Kafka, such as what...
|
|
|
Author: Evan Chan,
2011-11-18, 17:37
|
|
|
Re: Popularity - Kafka - [mail # user]
|
|
...Kafka itself would not do real-time analysis, but you can easily set up a Kafka consumer or consumers and feed the logs into a stream processing system. The use of markers in Kafka (to...
|
|
|
Author: Evan Chan,
2011-11-03, 22:10
|
|
|
|
