public class TierTopicMaterializationUtils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
TierTopicMaterializationToolConfig |
config |
org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> |
consumer |
java.util.HashMap<TopicIdPartition,FileTierPartitionState> |
stateMap |
Constructor and Description |
---|
TierTopicMaterializationUtils(TierTopicMaterializationToolConfig config,
java.util.HashMap<TopicIdPartition,java.lang.Long> offsetMap) |
Modifier and Type | Method and Description |
---|---|
java.nio.file.Path |
getTierStateFile(TopicIdPartition id) |
void |
run() |
void |
setupConsumer(TierTopicMaterializationToolConfig config) |
public org.apache.kafka.clients.consumer.KafkaConsumer<byte[],byte[]> consumer
public TierTopicMaterializationToolConfig config
public java.util.HashMap<TopicIdPartition,FileTierPartitionState> stateMap
public TierTopicMaterializationUtils(TierTopicMaterializationToolConfig config, java.util.HashMap<TopicIdPartition,java.lang.Long> offsetMap)
public void setupConsumer(TierTopicMaterializationToolConfig config)
public void run() throws java.io.IOException
java.io.IOException
public java.nio.file.Path getTierStateFile(TopicIdPartition id)