root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: improve KafkaStreams replication factor documentation (#9829) 

Reviewers: Jason Gustafson <jason@confluent.io>, Jim Galasyn <jim.galasyn@confluent.io>
This commit is contained in:
Matthias J. Sax 2021-01-06 11:31:05 -08:00 committed by GitHub
parent bf55afecda
commit 2e0c686ec1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
docs/streams/developer-guide/config-streams.html
View File

@ -304,7 +304,8 @@
</tr>
<tr class="row-even"><td>replication.factor</td>
<td>High</td>
<td colspan="2">The replication factor for changelog topics and repartition topics created by the application.</td>
<td colspan="2">The replication factor for changelog topics and repartition topics created by the application.
If your broker cluster is on version 2.4 or newer, you can set -1 to use the broker default replication factor.</td>
<td>1</td>
</tr>
<tr class="row-even"><td>retry.backoff.ms</td>

3
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
View File

@ -484,7 +484,8 @@ public class StreamsConfig extends AbstractConfig {
/** {@code replication.factor} */
@SuppressWarnings("WeakerAccess")
public static final String REPLICATION_FACTOR_CONFIG = "replication.factor";
private static final String REPLICATION_FACTOR_DOC = "The replication factor for change log topics and repartition topics created by the stream processing application.";
private static final String REPLICATION_FACTOR_DOC = "The replication factor for change log topics and repartition topics created by the stream processing application." +
" If your broker cluster is on version 2.4 or newer, you can set -1 to use the broker default replication factor.";
/** {@code request.timeout.ms} */
@SuppressWarnings("WeakerAccess")