public static class KafkaSettings.Builder extends Object
| Constructor and Description |
|---|
Builder() |
| Modifier and Type | Method and Description |
|---|---|
KafkaSettings.Builder |
autoCreateTopicsEnable(Boolean autoCreateTopicsEnable)
Enable auto creation of topic on the server.
|
KafkaSettings.Builder |
bootstrapServers(String bootstrapServers)
Bootstrap servers.
|
KafkaSettings |
build() |
KafkaSettings.Builder |
copy(KafkaSettings model) |
KafkaSettings.Builder |
logRetentionHours(Integer logRetentionHours)
The number of hours to keep a log file before deleting it (in hours).
|
KafkaSettings.Builder |
numPartitions(Integer numPartitions)
The default number of log partitions per topic.
|
public KafkaSettings.Builder bootstrapServers(String bootstrapServers)
Bootstrap servers.
bootstrapServers - the value to setpublic KafkaSettings.Builder autoCreateTopicsEnable(Boolean autoCreateTopicsEnable)
Enable auto creation of topic on the server.
autoCreateTopicsEnable - the value to setpublic KafkaSettings.Builder logRetentionHours(Integer logRetentionHours)
The number of hours to keep a log file before deleting it (in hours).
logRetentionHours - the value to setpublic KafkaSettings.Builder numPartitions(Integer numPartitions)
The default number of log partitions per topic.
numPartitions - the value to setpublic KafkaSettings build()
public KafkaSettings.Builder copy(KafkaSettings model)
Copyright © 2016–2022. All rights reserved.