Skip to content

Commit b1b4d77

Browse files
Set Kafka progress topic 'segment.bytes' config to 128 MB by default
1 parent 6895c58 commit b1b4d77

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/sql/src/plan/statement/ddl/connection.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -334,6 +334,7 @@ impl ConnectionOptionExtracted {
334334
}).transpose()?,
335335
topic_config: btreemap! {
336336
"cleanup.policy".to_string() => "compact".to_string(),
337+
"segment.bytes".to_string() => "134217728".to_string(), // 128 MB
337338
},
338339
},
339340
options: BTreeMap::new(),

0 commit comments

Comments
 (0)