Great thanks!
On Mon, Aug 10, 2015 at 7:03 PM, Ewen Cheslack-Postava e...@confluent.io
wrote:
Right now I think the only place the new API is documented is in the
javadocs. Here are the relevant sections for replacing the simple consumer.
Subscribing to specific partitions:
Right now I think the only place the new API is documented is in the
javadocs. Here are the relevant sections for replacing the simple consumer.
Subscribing to specific partitions:
Ewen,
Do you have an example or link for the changes/plans that will bring the
benefits you describe?
Cheers,
Joe Lawson
On Aug 10, 2015 3:27 PM, Ewen Cheslack-Postava e...@confluent.io wrote:
You can do this using the SimpleConsumer. See
You can do this using the SimpleConsumer. See
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
for details with some code.
When the new consumer is released in 0.8.3, this will get a *lot* simpler.
-Ewen
On Fri, Aug 7, 2015 at 9:26 AM, Padgett, Ben
Does anyone have an example of how to get a single record from a
topic+partition given a specific offset?
I am interested in this for some retry logic for failed messages.
Thanks!
