Class SimpleConsumeManagerImpl

java.lang.Object

io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl

All Implemented Interfaces:

SimpleConsumeManager

public final class SimpleConsumeManagerImpl
extends Object
implements SimpleConsumeManager

Constructor Summary

Constructors

Constructor	Description
SimpleConsumeManagerImpl(KafkaConsumerProvider consumerProvider, ExecutorService simpleConsumeExecutor)

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)
static int	getOverallSerializedMessageSize(List<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>> kafkaRecords)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SimpleConsumeManagerImpl

@Inject
public SimpleConsumeManagerImpl(KafkaConsumerProvider consumerProvider,
 ExecutorService simpleConsumeExecutor)

Method Details

consumeFromPartition

public CompletableFuture<PartitionConsumeData> consumeFromPartition(@Nonnull
 org.apache.kafka.common.TopicPartition partition,
 Boolean fromBeginning,
 Long timestamp,
 Long offset,
 Integer maxPollRecords,
 Integer fetchMaxBytes,
 Integer messageMaxBytes)

Specified by:

consumeFromPartition in interface SimpleConsumeManager

consumeFromMultiplePartitions

public 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)

Specified by:

consumeFromMultiplePartitions in interface SimpleConsumeManager

getOverallSerializedMessageSize

public static int getOverallSerializedMessageSize(List<org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]>> kafkaRecords)

getOffsetForPartition

public CompletableFuture<Long> getOffsetForPartition(@Nonnull
 org.apache.kafka.common.TopicPartition partition,
 Boolean fromBeginning,
 Long timestamp)

Specified by:

getOffsetForPartition in interface SimpleConsumeManager

getOffsetsForPartitions

public CompletableFuture<PartitionsOffsetsData> getOffsetsForPartitions(@Nonnull
 String topicName,
 int numPartitions,
 Boolean fromBeginning,
 Long timestamp)

Specified by:

getOffsetsForPartitions in interface SimpleConsumeManager