Skip to content

Commit f45ce2b

Browse files
authored
feat: support configuring message.max.bytes for kafka external streams (#352)
1 parent 7a82197 commit f45ce2b

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/Storages/ExternalStream/Kafka/KafkaSink.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -141,6 +141,7 @@ KafkaSink::KafkaSink(const Kafka * kafka, const Block & header, ContextPtr conte
141141
"queue.buffering.max.messages",
142142
"queue.buffering.max.kbytes",
143143
"queue.buffering.max.ms",
144+
"message.max.bytes",
144145
"message.send.max.retries",
145146
"retries",
146147
"retry.backoff.ms",

0 commit comments

Comments
 (0)