Interface SimpleConsumeManager
- All Known Implementing Classes:
SimpleConsumeManagerImpl
public interface SimpleConsumeManager
-
Method Summary
Modifier and TypeMethodDescriptionconsumeFromMultiplePartitions(String topicName, int numPartitions, Map<Integer, Long> offsets, Boolean fromBeginning, Long timestamp, Integer maxPollRecords, Integer fetchMaxBytes, Integer messageMaxBytes, boolean guaranteeProgressForEachPartition, boolean returnRawBase64Records) consumeFromPartition(org.apache.kafka.common.TopicPartition partition, Boolean fromBeginning, Long timestamp, Long offset, Integer maxPollRecords, Integer fetchMaxBytes, Integer messageMaxBytes) getOffsetForPartition(org.apache.kafka.common.TopicPartition partition, Boolean fromBeginning, Long timestamp) getOffsetsForPartitions(String topicName, int numPartitions, Boolean fromBeginning, Long timestamp)
-
Method Details
-
consumeFromPartition
CompletableFuture<PartitionConsumeData> consumeFromPartition(@Nonnull org.apache.kafka.common.TopicPartition partition, Boolean fromBeginning, Long timestamp, Long offset, Integer maxPollRecords, Integer fetchMaxBytes, Integer messageMaxBytes) -
consumeFromMultiplePartitions
CompletableFuture<List<PartitionConsumeData>> consumeFromMultiplePartitions(@Nonnull String topicName, int numPartitions, Map<Integer, Long> offsets, Boolean fromBeginning, Long timestamp, Integer maxPollRecords, Integer fetchMaxBytes, Integer messageMaxBytes, boolean guaranteeProgressForEachPartition, boolean returnRawBase64Records) -
getOffsetForPartition
CompletableFuture<Long> getOffsetForPartition(@Nonnull org.apache.kafka.common.TopicPartition partition, Boolean fromBeginning, Long timestamp) -
getOffsetsForPartitions
CompletableFuture<PartitionsOffsetsData> getOffsetsForPartitions(@Nonnull String topicName, int numPartitions, Boolean fromBeginning, Long timestamp)
-