Package org.springframework.kafka.config
Interface KafkaListenerContainerFactory<C extends MessageListenerContainer>
- Type Parameters:
C
- theMessageListenerContainer
implementation type.
- All Known Implementing Classes:
AbstractKafkaListenerContainerFactory
,ConcurrentKafkaListenerContainerFactory
public interface KafkaListenerContainerFactory<C extends MessageListenerContainer>
Factory for
MessageListenerContainer
s.- Author:
- Stephane Nicoll, Gary Russell
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptioncreateContainer
(String... topics) Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.createContainer
(Pattern topicPattern) Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.createContainer
(TopicPartitionOffset... topicPartitions) Create and configure a container without a listener; used to create containers that are not used for KafkaListener annotations.createListenerContainer
(KafkaListenerEndpoint endpoint) Create aMessageListenerContainer
for the givenKafkaListenerEndpoint
.
-
Method Details
-
createListenerContainer
Create aMessageListenerContainer
for 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
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
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
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
-