Package org.springframework.kafka.core
Class KafkaResourceFactory
java.lang.Object
org.springframework.kafka.core.KafkaResourceFactory
- Direct Known Subclasses:
DefaultKafkaConsumerFactory,DefaultKafkaProducerFactory,KafkaAdmin
Base class for consumer/producer/admin creators.
- Since:
- 2.5
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidcheckBootstrap(Map<String, Object> configs) Enhance the properties by calling thesetBootstrapServersSupplier(Supplier)and replace the bootstrap servers properties.protected StringvoidsetBootstrapServersSupplier(Supplier<String> bootstrapServersSupplier) Set a supplier for the bootstrap server list to override any configured in a subclass.
-
Constructor Details
-
KafkaResourceFactory
public KafkaResourceFactory()
-
-
Method Details
-
getBootstrapServers
-
setBootstrapServersSupplier
Set a supplier for the bootstrap server list to override any configured in a subclass.- Parameters:
bootstrapServersSupplier- the supplier.
-
checkBootstrap
Enhance the properties by calling thesetBootstrapServersSupplier(Supplier)and replace the bootstrap servers properties.- Parameters:
configs- the configs.
-