Spring Integration Kafka Support

org.springframework.integration.kafka.support
Class TopicFilterConfiguration

java.lang.Object
  extended by org.springframework.integration.kafka.support.TopicFilterConfiguration

public class TopicFilterConfiguration
extends java.lang.Object

Since:
0.5
Author:
Rajasekar Elango, Artem Bilan

Constructor Summary
TopicFilterConfiguration(java.lang.String pattern, int numberOfStreams, boolean exclude)
           
 
Method Summary
 int getNumberOfStreams()
           
 kafka.consumer.TopicFilter getTopicFilter()
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

TopicFilterConfiguration

public TopicFilterConfiguration(java.lang.String pattern,
                                int numberOfStreams,
                                boolean exclude)
Method Detail

getTopicFilter

public kafka.consumer.TopicFilter getTopicFilter()

getNumberOfStreams

public int getNumberOfStreams()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

Spring Integration Kafka Support