Skip to content

Commit

Permalink
sink max 8 chunk at once by default for kafka and kinesis
Browse files Browse the repository at this point in the history
  • Loading branch information
oguzhanunlu committed May 20, 2024
1 parent d547164 commit cfc3b33
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion config/config.kafka.extended.hocon
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@
# Number of events that can get enriched at the same time within a chunk
"enrich": 256
# Number of chunks that can get sunk at the same time
"sink": 256
"sink": 8
}

# Optional, period after which enrich assets should be checked for updates
Expand Down
2 changes: 1 addition & 1 deletion config/config.kinesis.extended.hocon
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@
# Number of events that can get enriched at the same time within a chunk
"enrich": 256
# Number of chunks that can get sunk at the same time
"sink": 256
"sink": 8
}

# Optional, period after which enrich assets should be checked for updates
Expand Down
2 changes: 1 addition & 1 deletion modules/kafka/src/main/resources/application.conf
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@

"concurrency" : {
"enrich": 256
"sink": 256
"sink": 8
}

"remoteAdapters" : {
Expand Down
2 changes: 1 addition & 1 deletion modules/kinesis/src/main/resources/application.conf
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@

"concurrency" : {
"enrich": 256
"sink": 256
"sink": 8
}

"remoteAdapters" : {
Expand Down

0 comments on commit cfc3b33

Please sign in to comment.