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–2024. All rights reserved.