public class InternalTopicManager
extends java.lang.Object
Constructor and Description |
---|
InternalTopicManager(org.apache.kafka.clients.admin.AdminClient adminClient,
StreamsConfig streamsConfig) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,java.lang.Integer> |
getNumPartitions(java.util.Set<java.lang.String> topics)
Try to get the number of partitions for the given topics; return the number of partitions for topics that already exists.
|
void |
makeReady(java.util.Map<java.lang.String,InternalTopicConfig> topics)
Prepares a set of given internal topics.
|
public InternalTopicManager(org.apache.kafka.clients.admin.AdminClient adminClient, StreamsConfig streamsConfig)
public void makeReady(java.util.Map<java.lang.String,InternalTopicConfig> topics)
protected java.util.Map<java.lang.String,java.lang.Integer> getNumPartitions(java.util.Set<java.lang.String> topics)