Package org.apache.kafka.streams.processor.internals

Class InternalTopicManager

java.lang.Object

org.apache.kafka.streams.processor.internals.InternalTopicManager

public class InternalTopicManager
extends Object

Constructor Summary

Constructors

Constructor	Description
InternalTopicManager(Admin adminClient, StreamsConfig streamsConfig)

Method Summary

Modifier and Type	Method	Description
protected Map<String,Integer>	getNumPartitions(Set<String> topics)	Try to get the number of partitions for the given topics; return the number of partitions for topics that already exists.
Set<String>	makeReady(Map<String,InternalTopicConfig> topics)	Prepares a set of given internal topics.

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalTopicManager

public InternalTopicManager(Admin adminClient,
                            StreamsConfig streamsConfig)

Method Detail

makeReady

public Set<String> makeReady(Map<String,InternalTopicConfig> topics)

Prepares a set of given internal topics. If a topic does not exist creates a new topic. If a topic with the correct number of partitions exists ignores it. If a topic exists already but has different number of partitions we fail and throw exception requesting user to reset the app before restarting again.

Returns:

the set of topics which had to be newly created

getNumPartitions

protected Map<String,Integer> getNumPartitions(Set<String> topics)

Try to get the number of partitions for the given topics; return the number of partitions for topics that already exists. Topics that were not able to get its description will simply not be returned