You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Developers should be able to get an access to the Consumer instance contained in a ConsumerTask in order to perform some operations. For example to seek the consumer to a specific offset.
Proposed Change
New Public API
Add this new method the ConsumerTask class
fun <T> execute(action: (consumer: Consumer<K, V>) ->T): T
The text was updated successfully, but these errors were encountered:
Motivation
Developers should be able to get an access to the
Consumer
instance contained in aConsumerTask
in order to perform some operations. For example to seek the consumer to a specific offset.Proposed Change
New Public API
Add this new method the
ConsumerTask
classThe text was updated successfully, but these errors were encountered: