Skip to content

Commit 122c580

Browse files
Heng CuiHeng Cui
authored andcommitted
update kafka streams probing rebalance interval
1 parent fcdf57a commit 122c580

3 files changed

Lines changed: 3 additions & 0 deletions

File tree

candyfloss/src/main/resources/application.dev.conf

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ kafka {
1212
compression.type = gzip
1313
replication.factor = 2
1414
num.stream.threads = 2
15+
probing.rebalance.interval.ms = 120000
1516
}
1617
kstream {
1718
input.topic.name = dev.device-json-raw-input

candyfloss/src/main/resources/application.prod.conf

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ kafka {
1212
compression.type = gzip
1313
replication.factor = 2
1414
num.stream.threads = 2
15+
probing.rebalance.interval.ms = 120000
1516
}
1617
kstream {
1718
input.topic.name = prod.device-json-raw-input

candyfloss/src/main/resources/application.test.conf

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ kafka {
1212
compression.type = gzip
1313
replication.factor = 2
1414
num.stream.threads = 2
15+
probing.rebalance.interval.ms = 120000
1516
}
1617
kstream {
1718
input.topic.name = test.device-json-raw-input

0 commit comments

Comments
 (0)