Package | Description |
---|---|
io.apicurio.registry.utils.kafka |
Modifier and Type | Interface and Description |
---|---|
static interface |
ConsumerActions.DynamicAssignment<K,V>
Implementation of actions that allow dynamic assignment of topic/partitions.
|
Modifier and Type | Class and Description |
---|---|
class |
ConsumerContainer<K,V>
A single-threaded Kafka Consumer container that is able to
ConsumerContainer.submit(Function) actions
from other threads to be executed asynchronously in the single consumer thread. |
Copyright © 2019 Red Hat. All rights reserved.