C - the MessageListenerContainer implementation type.public interface KafkaListenerContainerFactory<C extends MessageListenerContainer>
MessageListenerContainers.KafkaListenerEndpoint| Modifier and Type | Method and Description |
|---|---|
C |
createContainer(java.util.Collection<TopicPartitionInitialOffset> topicPartitions)
Create and configure a container without a listener; used to create containers that
are not used for KafkaListener annotations.
|
C |
createContainer(java.util.regex.Pattern topicPattern)
Create and configure a container without a listener; used to create containers that
are not used for KafkaListener annotations.
|
C |
createContainer(java.lang.String... topics)
Create and configure a container without a listener; used to create containers that
are not used for KafkaListener annotations.
|
C |
createListenerContainer(KafkaListenerEndpoint endpoint)
Create a
MessageListenerContainer for the given KafkaListenerEndpoint. |
C createListenerContainer(KafkaListenerEndpoint endpoint)
MessageListenerContainer for the given KafkaListenerEndpoint.
Containers created using this method are added to the listener endpoint registry.endpoint - the endpoint to configureC createContainer(java.util.Collection<TopicPartitionInitialOffset> topicPartitions)
topicPartitions - the topicPartitions.C createContainer(java.lang.String... topics)
topics - the topics.C createContainer(java.util.regex.Pattern topicPattern)
topicPattern - the topicPattern.