From 190f1376a2e46781abc010aefc8c87844fe1e06a Mon Sep 17 00:00:00 2001
From: tchiotludo <tchiot.ludo@gmail.com>
Date: Wed, 5 Jan 2022 20:37:31 +0100
Subject: [PATCH] chore(test): fix falling test

---
 src/main/java/org/akhq/repositories/RecordRepository.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/akhq/repositories/RecordRepository.java b/src/main/java/org/akhq/repositories/RecordRepository.java
index 3c1887336..fbbf57d78 100644
--- a/src/main/java/org/akhq/repositories/RecordRepository.java
+++ b/src/main/java/org/akhq/repositories/RecordRepository.java
@@ -77,8 +77,8 @@ public class RecordRepository extends AbstractRepository {
     @Value("${akhq.clients-defaults.consumer.properties.max.poll.records:50}")
     protected int maxPollRecords;
 
-    @Value("${akhq.topic-data.kafka-max-message-length}")
-    private int maxKafkaMessageLength;
+    @Value("${akhq.topic-data.kafka-max-message-length:2147483647}")
+    protected int maxKafkaMessageLength;
 
     public Map<String, Record> getLastRecord(String clusterId, List<String> topicsName) throws ExecutionException, InterruptedException {
         Map<String, Topic> topics = topicRepository.findByName(clusterId, topicsName).stream()
@@ -1276,6 +1276,10 @@ private static class EndOffsetBound {
     }
 
     private void filterMessageLength(Record record) {
+        if (maxKafkaMessageLength == Integer.MAX_VALUE) {
+            return;
+        }
+
         int bytesLength = record.getValue().getBytes(StandardCharsets.UTF_8).length;
         if (bytesLength > maxKafkaMessageLength) {
             int substringChars = maxKafkaMessageLength / 1000;