C
- the MessageListenerContainer
implementation type.public interface KafkaListenerContainerFactory<C extends MessageListenerContainer>
MessageListenerContainer
s.KafkaListenerEndpoint
Modifier and Type | Method and Description |
---|---|
C |
createContainer(java.util.Collection<TopicPartitionInitialOffset> topicPartitions)
Deprecated.
in favor of
createContainer(TopicPartitionOffset[]) . |
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 configure@Deprecated C createContainer(java.util.Collection<TopicPartitionInitialOffset> topicPartitions)
createContainer(TopicPartitionOffset[])
.topicPartitions
- the topicPartitions to assign.C 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.