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