Class SimpleConsumeManagerImpl
java.lang.Object
io.confluent.kafkarest.controllers.SimpleConsumeManagerImpl
- All Implemented Interfaces:
SimpleConsumeManager
-
Constructor Summary
ConstructorsConstructorDescriptionSimpleConsumeManagerImpl(KafkaConsumerProvider consumerProvider, ExecutorService simpleConsumeExecutor) -
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) static intgetOverallSerializedMessageSize(List<org.apache.kafka.clients.consumer.ConsumerRecord<byte[], byte[]>> kafkaRecords)
-
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:
consumeFromPartitionin interfaceSimpleConsumeManager
-
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:
consumeFromMultiplePartitionsin interfaceSimpleConsumeManager
-
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:
getOffsetForPartitionin interfaceSimpleConsumeManager
-
getOffsetsForPartitions
public CompletableFuture<PartitionsOffsetsData> getOffsetsForPartitions(@Nonnull String topicName, int numPartitions, Boolean fromBeginning, Long timestamp) - Specified by:
getOffsetsForPartitionsin interfaceSimpleConsumeManager
-