异常修复

mainFactory/src/main/java/org/bfkj/protocol/MyKafKa.java

@@ -33,6 +33,7 @@ public class MyKafKa {
         connectConfigMaps.put("max.poll.records", pollNumber == null ? 1 : Integer.parseInt(pollNumber));
         connectConfigMaps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
         connectConfigMaps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
+        connectConfigMaps.put("max.partition.fetch.bytes", 11534336);
 
         if (Objects.isNull(consumer)) {
             consumer = new KafkaConsumer<>(connectConfigMaps);