Skip to content

Commit

Permalink
[improve][broker] Add missing configuration keys for caching catch-up…
Browse files Browse the repository at this point in the history
… reads (#22295)
  • Loading branch information
lhotari committed Mar 19, 2024
1 parent 1b1bd4b commit 2803ba2
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 3 deletions.
12 changes: 11 additions & 1 deletion conf/broker.conf
Original file line number Diff line number Diff line change
Expand Up @@ -1147,6 +1147,16 @@ managedLedgerCacheEvictionTimeThresholdMillis=1000
# and thus should be set as inactive.
managedLedgerCursorBackloggedThreshold=1000

# Minimum cursors that must be in backlog state to cache and reuse the read entries.
# (Default =0 to disable backlog reach cache)
managedLedgerMinimumBacklogCursorsForCaching=0

# Minimum backlog entries for any cursor before start caching reads.
managedLedgerMinimumBacklogEntriesForCaching=1000

# Maximum backlog entry difference to prevent caching entries that can't be reused.
managedLedgerMaxBacklogBetweenCursorsForCaching=1000

# Rate limit the amount of writes per second generated by consumer acking the messages
managedLedgerDefaultMarkDeleteRateLimit=1.0

Expand Down Expand Up @@ -1849,4 +1859,4 @@ brokerInterceptorsDirectory=./interceptors
brokerInterceptors=

# Enable or disable the broker interceptor, which is only used for testing for now
disableBrokerInterceptors=true
disableBrokerInterceptors=true
4 changes: 2 additions & 2 deletions conf/standalone.conf
Original file line number Diff line number Diff line change
Expand Up @@ -807,10 +807,10 @@ managedLedgerNewEntriesCheckDelayInMillis=10
managedLedgerMinimumBacklogCursorsForCaching=0

# Minimum backlog entries for any cursor before start caching reads.
managedLedgerMinimumBacklogEntriesForCaching=100
managedLedgerMinimumBacklogEntriesForCaching=1000

# Maximum backlog entry difference to prevent caching entries that can't be reused.
managedLedgerMaxBacklogBetweenCursorsForCaching=10000
managedLedgerMaxBacklogBetweenCursorsForCaching=1000

# Use Open Range-Set to cache unacked messages
managedLedgerUnackedRangesOpenCacheSetEnabled=true
Expand Down

0 comments on commit 2803ba2

Please sign in to comment.