Interface SimpleConsumeManager

All Known Implementing Classes:

SimpleConsumeManagerImpl

public interface SimpleConsumeManager

Method Summary

Modifier and Type	Method	Description
CompletableFuture<List<PartitionConsumeData>>	consumeFromMultiplePartitions(String topicName, int numPartitions, Map<Integer,Long> offsets, Boolean fromBeginning, Long timestamp, Integer maxPollRecords, Integer fetchMaxBytes, Integer messageMaxBytes, boolean guaranteeProgressForEachPartition, boolean returnRawBase64Records)
CompletableFuture<PartitionConsumeData>	consumeFromPartition(org.apache.kafka.common.TopicPartition partition, Boolean fromBeginning, Long timestamp, Long offset, Integer maxPollRecords, Integer fetchMaxBytes, Integer messageMaxBytes)
CompletableFuture<Long>	getOffsetForPartition(org.apache.kafka.common.TopicPartition partition, Boolean fromBeginning, Long timestamp)
CompletableFuture<PartitionsOffsetsData>	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)