| clear query|facets|time |
Search criteria: .
Results from 11 to 20 from
27 (0.138s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: MULTI FETCH RESPONSE Wire Format for Kafka 0.7.1 - Kafka - [mail # dev]
|
|
...After doing a little wire-snooping of the data, it appears that the MULTI-FETCH RESPONSE is EXACTLY the same as the SINGLE-FETCH. If this is correct, how does one advance to the next o...
|
|
|
Author: Milind Parikh,
2012-09-28, 22:56
|
|
|
MULTI FETCH RESPONSE Wire Format for Kafka 0.7.1 - Kafka - [mail # dev]
|
|
...What is the wire format for MULTI-FETCH *RESPONSE* *given *that the SINGLE-FETCH RESPONSE LOOKS like this: ...
|
|
|
Author: Milind Parikh,
2012-09-28, 21:38
|
|
|
Re: Wire format for Kafka 0.7.1 - Kafka - [mail # user]
|
|
...Jun I was just bashing myself for not having read the spec carefully; particularly the magic byte. The Java producer seems to use a different encoder for strings. I am, now, able...
|
|
|
Author: Milind Parikh,
2012-09-28, 16:08
|
|
|
Wire format for Kafka 0.7.1 - Kafka - [mail # user]
|
|
...I am writing an erlang driver for Kafka. I am using the spec from https://cwiki.apache.org/confluence/display/KAFKA/Writing+a+Driver+for+Kafka. Just learnt something that I thought should be...
|
|
|
Author: Milind Parikh,
2012-09-27, 06:21
|
|
|
Re: kafka partitioning - Kafka - [mail # user]
|
|
...As I understand it, this partition is a broker_partion pair (in a multi broker scenario). again as I understand it : if , on the consumer side, stickness (same key goes to same consume...
|
|
|
Author: Milind Parikh,
2012-09-25, 22:59
|
|
|
Re: Re: can high-level consumer api provide the method getting messages with non-block? - Kafka - [mail # user]
|
|
...Neha To elaborate a little bit more, Countandra 0.7 architecture is depicted in this link. https://docs.google.com/drawings/d/1E9h5NodQVaA6iqxmcEYz9EZGapiNhLVHDI67XdXBBOo/edit &n...
|
|
|
Author: Milind Parikh,
2012-03-09, 03:36
|
|
|
Re: Re: can high-level consumer api provide the method getting messages with non-block? - Kafka - [mail # user]
|
|
...I introduced a sleep to let rebalance make place to account for 242 before new createmessagestream. However to no avail. Therefore it appears that without the resolution of 242, the co...
|
|
|
Author: Milind Parikh,
2012-03-08, 01:19
|
|
|
Re: can high-level consumer api provide the method getting messages with non-block? - Kafka - [mail # user]
|
|
...Using a timeout of >0 on the broker will throw a timeout on consumer. /*********************** sent from my android...please pardon occasional typos as I respond @ the speed of thou...
|
|
|
Author: Milind Parikh,
2012-03-02, 12:49
|
|
|
Re: ways to exit the blocking iterator - Kafka - [mail # user]
|
|
...Neha Thanks. I am looking for the semantics of ensuring that ALL consumers would somehow unblock. This is probably not doable with the queue semantics. /*********************** sent fr...
|
|
|
Author: Milind Parikh,
2012-02-29, 03:37
|
|
|
ways to exit the blocking iterator - Kafka - [mail # user]
|
|
...I need to exit the blocking consumer iterator on certain conditions ; do some other processing and then resume the blocking iterartor. All of the work is dependent on the "other processing"....
|
|
|
Author: Milind Parikh,
2012-02-28, 13:29
|
|
|
|
