| clear query|facets|time |
Search criteria: .
Results from 11 to 20 from
23 (0.091s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: createMessageStreamsByFilter unexpected behaviour - Kafka - [mail # user]
|
|
...Thanks Jun, will rebuild our maven libraries, we're running on trunk code already :). On 20 November 2012 17:15, Jun Rao wrote: Michal Haris Software Engineer ...
|
|
|
Author: Michal Haris,
2012-11-21, 19:04
|
|
|
createMessageStreamsByFilter unexpected behaviour - Kafka - [mail # user]
|
|
...Hi, I am seeing behaviour which I am not expecting when using topic filters. TopicFilter sourceTopicFilter = new Whitelist("pageviews"); List> streams consumer.createMessageSt...
|
|
|
Author: Michal Haris,
2012-11-20, 12:44
|
|
|
Re: Question about resetting offsets and the high-level consumer - Kafka - [mail # user]
|
|
...Well, resetting could follow the partition ownership where only owned partitions can be reset by any one consumer. There's definitely a case for consumer applications that are more about obs...
|
|
|
Author: Michal Haris,
2012-11-16, 00:22
|
|
|
Re: Question about resetting offsets and the high-level consumer - Kafka - [mail # user]
|
|
...Of course assuming that none of the consumers in the group are interested in the missed messages in such case. On Nov 12, 2012 6:03 AM, "Jun Rao" wrote: ...
|
|
|
Author: Michal Haris,
2012-11-14, 00:08
|
|
|
Re: Question about resetting offsets and the high-level consumer - Kafka - [mail # user]
|
|
...Found it in archives, autooffset.reset is only used when the consumer registering first time or the last committed offset is out-of-range, so that means that we have to create direct connect...
|
|
|
Author: Michal Haris,
2012-11-10, 14:41
|
|
|
Re: Question about resetting offsets and the high-level consumer - Kafka - [mail # user]
|
|
...Really? So what does the autooffset.reset=largest do ? On Nov 9, 2012 3:30 PM, "Jun Rao" wrote: ...
|
|
|
Author: Michal Haris,
2012-11-10, 11:40
|
|
|
some code to share - Kafka - [mail # user]
|
|
...Hi all, I have just generalized some of my latest work on partitioned mirroring which I'm using in a semi-production mode and will be updating it as we go live - https://github.com/mic...
|
|
|
Author: Michal Haris,
2012-11-03, 17:39
|
|
|
Partitioning strategies - Kafka - [mail # user]
|
|
...Hi, Would it be reasonable to say that deterministic partotioner should always be deciding on attributes with high cardinality? I.e. with low cardinality some partitions would en...
|
|
|
Author: Michal Haris,
2012-11-03, 14:09
|
|
|
Re: Scenarios of Hadoop producers and consumers - Kafka - [mail # user]
|
|
...When you need your data streams to be incrementally loaded into hadoop for offline batch processing and/or ad-hoc querying - some things cannot (or are expensive to) be computed in real-time...
|
|
|
Author: Michal Haris,
2012-10-31, 00:40
|
|
|
Re: Our scenario and couple of questions - Kafka - [mail # user]
|
|
...Oh, one more aspect of the problem: The event stream can be potentially split into multiple topics and I have an idea how and with what partitioning but since the mirroring doesn't obey the ...
|
|
|
Author: Michal Haris,
2012-10-18, 09:46
|
|
|
|
