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

Class CopartitionedTopicsEnforcer

java.lang.Object

org.apache.kafka.streams.processor.internals.assignment.CopartitionedTopicsEnforcer

public class CopartitionedTopicsEnforcer
extends Object

Constructor Summary

Constructors

Constructor	Description
CopartitionedTopicsEnforcer(String logPrefix)

Method Summary

Modifier and Type	Method	Description
void	enforce(Set<String> copartitionGroup, Map<String,InternalTopicConfig> allRepartitionTopicsNumPartitions, Cluster metadata)

Methods inherited from class java.lang.Object

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

Constructor Detail

CopartitionedTopicsEnforcer

public CopartitionedTopicsEnforcer(String logPrefix)

Method Detail

enforce

public void enforce(Set<String> copartitionGroup,
                    Map<String,InternalTopicConfig> allRepartitionTopicsNumPartitions,
                    Cluster metadata)