public class TierTopicMaterializationUtils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> |
consumer |
Constructor and Description |
---|
TierTopicMaterializationUtils(TierTopicMaterializationToolConfig config,
java.util.Properties additionalConsumerProps) |
TierTopicMaterializationUtils(TierTopicMaterializationToolConfig config,
java.util.Properties additionalConsumerProps,
java.util.Map<TopicIdPartition,java.lang.Long> offsetMap) |
Modifier and Type | Method and Description |
---|---|
long |
getStartOffset(org.apache.kafka.common.TopicPartition tp)
getStartOffset will return the beginning offset of a given TopicPartition 'tp'.
|
java.nio.file.Path |
getTierStateFile(TopicIdPartition id) |
void |
run() |
void |
setupConsumer(TierTopicMaterializationToolConfig config) |
public org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> consumer
public TierTopicMaterializationUtils(TierTopicMaterializationToolConfig config, java.util.Properties additionalConsumerProps, java.util.Map<TopicIdPartition,java.lang.Long> offsetMap)
public TierTopicMaterializationUtils(TierTopicMaterializationToolConfig config, java.util.Properties additionalConsumerProps)
public void setupConsumer(TierTopicMaterializationToolConfig config)
public void run() throws java.io.IOException
java.io.IOException
public java.nio.file.Path getTierStateFile(TopicIdPartition id)
public long getStartOffset(org.apache.kafka.common.TopicPartition tp)
tp
- is TopicPartition