K
- V
- public static interface ConsumerActions.DynamicAssignment<K,V> extends ConsumerActions<K,V>
ConsumerActions.DynamicAssignment<K,V>
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<Void> |
addTopicPartition(org.apache.kafka.common.TopicPartition tp,
Seek.Offset seekOffset)
Dynamically add given topic partition with initial seek offset to the set of assigned topic partitions.
|
default CompletableFuture<Void> |
removeTopicParition(org.apache.kafka.common.TopicPartition tp)
Dynamically remove given topic partition from the set of assigned topic partitions.
|
isRunning, start, stop, submit
default CompletableFuture<Void> addTopicPartition(org.apache.kafka.common.TopicPartition tp, Seek.Offset seekOffset)
tp
- topic partitionseekOffset
- a specification for initial seekdefault CompletableFuture<Void> removeTopicParition(org.apache.kafka.common.TopicPartition tp)
tp
- topic partition to removeCopyright © 2019 Red Hat. All rights reserved.