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.