From 6190356a7edc532e460afcd25b2fe9a4ec5d2176 Mon Sep 17 00:00:00 2001 From: Benedith Mulongo Date: Mon, 16 Dec 2024 13:28:52 +0100 Subject: [PATCH] Update msg.max.bytes for cluster & topics --- kafka-resources/base/kafka-core/kafka-das-params-topic.yaml | 2 +- kafka-resources/base/kafka-core/kafka-das-topic.yaml | 2 +- kafka-resources/base/kafka-core/kafka-persistent-cluster.yaml | 3 ++- 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/kafka-resources/base/kafka-core/kafka-das-params-topic.yaml b/kafka-resources/base/kafka-core/kafka-das-params-topic.yaml index 0f3eded..f21d887 100644 --- a/kafka-resources/base/kafka-core/kafka-das-params-topic.yaml +++ b/kafka-resources/base/kafka-core/kafka-das-params-topic.yaml @@ -13,4 +13,4 @@ spec: # http://kafka.apache.org/documentation/#topicconfigs # max.message.bytes: x cleanup.policy: compact - max.message.bytes: 1073741824 + max.message.bytes: 5368709120 diff --git a/kafka-resources/base/kafka-core/kafka-das-topic.yaml b/kafka-resources/base/kafka-core/kafka-das-topic.yaml index 70147e1..8f18035 100644 --- a/kafka-resources/base/kafka-core/kafka-das-topic.yaml +++ b/kafka-resources/base/kafka-core/kafka-das-topic.yaml @@ -13,4 +13,4 @@ spec: # http://kafka.apache.org/documentation/#topicconfigs # max.message.bytes: x cleanup.policy: compact - max.message.bytes: 1073741824 + max.message.bytes: 5368709120 diff --git a/kafka-resources/base/kafka-core/kafka-persistent-cluster.yaml b/kafka-resources/base/kafka-core/kafka-persistent-cluster.yaml index 3042fe6..8fabd0f 100644 --- a/kafka-resources/base/kafka-core/kafka-persistent-cluster.yaml +++ b/kafka-resources/base/kafka-core/kafka-persistent-cluster.yaml @@ -34,7 +34,8 @@ spec: nodePort: 32700 config: # max.request.size: x - message.max.bytes: 1073741824 + message.max.bytes: 5368709120 + replica.fetch.max.bytes: 5368709120 offsets.topic.replication.factor: 1 transaction.state.log.replication.factor: 1 transaction.state.log.min.isr: 1