public abstract class KafkaResourceFactory
extends java.lang.Object
Constructor and Description |
---|
KafkaResourceFactory() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkBootstrap(java.util.Map<java.lang.String,java.lang.Object> configs)
Enhance the properties by calling the
setBootstrapServersSupplier(Supplier) amd replace the bootstrap servers
properties. |
protected java.lang.String |
getBootstrapServers() |
void |
setBootstrapServersSupplier(java.util.function.Supplier<java.lang.String> bootstrapServersSupplier)
Set a supplier for the bootstrap server list to override any configured in a
subclass.
|
@Nullable protected java.lang.String getBootstrapServers()
public void setBootstrapServersSupplier(java.util.function.Supplier<java.lang.String> bootstrapServersSupplier)
bootstrapServersSupplier
- the supplier.protected void checkBootstrap(java.util.Map<java.lang.String,java.lang.Object> configs)
setBootstrapServersSupplier(Supplier)
amd replace the bootstrap servers
properties.configs
- the configs.