org.springframework.cloud.stream.binder.kafka

Class KafkaMessageChannelBinder.TopicInformation

java.lang.Object

org.springframework.cloud.stream.binder.kafka.KafkaMessageChannelBinder.TopicInformation

Enclosing class:

KafkaMessageChannelBinder

public static class KafkaMessageChannelBinder.TopicInformation
extends Object

Constructor Summary

Constructors

Constructor and Description
TopicInformation(String consumerGroup, Collection<org.apache.kafka.common.PartitionInfo> partitionInfos)

Method Summary

Modifier and Type	Method and Description
String	getConsumerGroup()
Collection<org.apache.kafka.common.PartitionInfo>	getPartitionInfos()
boolean	isConsumerTopic()

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicInformation

public TopicInformation(String consumerGroup,
                        Collection<org.apache.kafka.common.PartitionInfo> partitionInfos)

Method Detail

getConsumerGroup

public String getConsumerGroup()

isConsumerTopic

public boolean isConsumerTopic()

getPartitionInfos

public Collection<org.apache.kafka.common.PartitionInfo> getPartitionInfos()