Is there any feature can support Consumer group just like Kafka

181 views
Skip to first unread message

李者璈

unread,
May 13, 2019, 1:35:32 PM5/13/19
to Disruptor
I want to use one producer to produce the data

and there will be multiple consumers to consume the same data.

I want to maintain an offset variable in the case when a consumer raises an Exception when consuming the data  so that we can retry the task by the begin of the offset

Michael Barker

unread,
May 13, 2019, 2:28:15 PM5/13/19
to lmax-di...@googlegroups.com
No, you can only drop the message or throw a RuntimeException from the ExecptionHandler which will cause the EventProcessor thread to exit.  This would need to be something you manage yourself.

--
You received this message because you are subscribed to the Google Groups "Disruptor" group.
To unsubscribe from this group and stop receiving emails from it, send an email to lmax-disrupto...@googlegroups.com.
To view this discussion on the web, visit https://groups.google.com/d/msgid/lmax-disruptor/5e1255e6-7316-4f4d-8988-b8719e5a430c%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
Reply all
Reply to author
Forward
0 new messages