Package org.springframework.kafka.config
Interface KafkaListenerContainerFactory<C extends MessageListenerContainer>
-
- Type Parameters:
C- theMessageListenerContainerimplementation type.
- All Known Implementing Classes:
AbstractKafkaListenerContainerFactory,ConcurrentKafkaListenerContainerFactory
public interface KafkaListenerContainerFactory<C extends MessageListenerContainer>Factory forMessageListenerContainers.- See Also:
KafkaListenerEndpoint
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CcreateContainer(java.lang.String... topics)Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.CcreateContainer(java.util.regex.Pattern topicPattern)Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.CcreateContainer(TopicPartitionOffset... topicPartitions)Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.CcreateListenerContainer(KafkaListenerEndpoint endpoint)Create aMessageListenerContainerfor the givenKafkaListenerEndpoint.
-
-
-
Method Detail
-
createListenerContainer
C createListenerContainer(KafkaListenerEndpoint endpoint)
Create aMessageListenerContainerfor the givenKafkaListenerEndpoint. Containers created using this method are added to the listener endpoint registry.- Parameters:
endpoint- the endpoint to configure- Returns:
- the created container
-
createContainer
C createContainer(TopicPartitionOffset... topicPartitions)
Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations. Containers created using this method are not added to the listener endpoint registry.- Parameters:
topicPartitions- the topicPartitions to assign.- Returns:
- the container.
- Since:
- 2.3
-
createContainer
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. Containers created using this method are not added to the listener endpoint registry.- Parameters:
topics- the topics.- Returns:
- the container.
- Since:
- 2.2
-
createContainer
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. Containers created using this method are not added to the listener endpoint registry.- Parameters:
topicPattern- the topicPattern.- Returns:
- the container.
- Since:
- 2.2
-
-