Package | Description |
---|---|
io.apicurio.registry.utils.kafka |
Modifier and Type | Method and Description |
---|---|
Seek.Offset |
Seek.offset(long offset) |
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<Void> |
ConsumerActions.DynamicAssignment.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.
|
Copyright © 2020 Red Hat. All rights reserved.