C
- the MessageListenerContainer
implementation type.public interface KafkaListenerContainerFactory<C extends MessageListenerContainer>
MessageListenerContainer
s.KafkaListenerEndpoint
Modifier and Type | Method and Description |
---|---|
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 |
createContainer(TopicPartitionOffset... topicPartitions)
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(TopicPartitionOffset... topicPartitions)
topicPartitions
- the topicPartitions to assign.C createContainer(java.lang.String... topics)
topics
- the topics.C createContainer(java.util.regex.Pattern topicPattern)
topicPattern
- the topicPattern.