Package io.streamthoughts.azkarra.api.streams.consumer

Class LogOffsetsFetcher

java.lang.Object

io.streamthoughts.azkarra.api.streams.consumer.LogOffsetsFetcher

public class LogOffsetsFetcher
extends Object

Constructor Summary

Constructors

Constructor	Description
LogOffsetsFetcher()

Method Summary

Modifier and Type	Method	Description
static <K,V> Map<org.apache.kafka.common.TopicPartition,Long>	fetchLogEndOffsetsFor(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, Collection<org.apache.kafka.common.TopicPartition> partitions)
static <K,V> Map<org.apache.kafka.common.TopicPartition,Long>	fetchLogStartOffsetsFor(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, Collection<org.apache.kafka.common.TopicPartition> partitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

LogOffsetsFetcher

public LogOffsetsFetcher()

Method Detail

fetchLogEndOffsetsFor

public static <K,V> Map<org.apache.kafka.common.TopicPartition,Long> fetchLogEndOffsetsFor(org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
                                                                                                       Collection<org.apache.kafka.common.TopicPartition> partitions)

fetchLogStartOffsetsFor

public static <K,V> Map<org.apache.kafka.common.TopicPartition,Long> fetchLogStartOffsetsFor(org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
                                                                                                         Collection<org.apache.kafka.common.TopicPartition> partitions)