Increase mai.bytes in BatchIndividualRecordObservationTests

artembilan · artembilan · commit e595bf249fbe · 2025-09-29T10:20:31.000-04:00
diff --git a/spring-kafka/src/test/java/org/springframework/kafka/support/micrometer/BatchIndividualRecordObservationTests.java b/spring-kafka/src/test/java/org/springframework/kafka/support/micrometer/BatchIndividualRecordObservationTests.java
@@ -187,7 +187,7 @@ ProducerFactory<Integer, String> producerFactory(EmbeddedKafkaBroker broker) {
 		@Bean
 		ConsumerFactory<Integer, String> consumerFactory(EmbeddedKafkaBroker broker) {
 			Map<String, Object> configs = KafkaTestUtils.consumerProps(broker, "batch-tests", false);
-			configs.put(ConsumerConfig.FETCH_MIN_BYTES_CONFIG, 54);
+			configs.put(ConsumerConfig.FETCH_MIN_BYTES_CONFIG, 100);
 			configs.put(ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG, 2000);
 			return new DefaultKafkaConsumerFactory<>(configs);
 		}

Original file line number	Diff line number	Diff line change
`@@ -187,7 +187,7 @@ ProducerFactory<Integer, String> producerFactory(EmbeddedKafkaBroker broker) {`
`187`	`187`	`@Bean`
`188`	`188`	`ConsumerFactory<Integer, String> consumerFactory(EmbeddedKafkaBroker broker) {`
`189`	`189`	`Map<String, Object> configs = KafkaTestUtils.consumerProps(broker, "batch-tests", false);`
`190`		`- configs.put(ConsumerConfig.FETCH_MIN_BYTES_CONFIG, 54);`
	`190`	`+ configs.put(ConsumerConfig.FETCH_MIN_BYTES_CONFIG, 100);`
`191`	`191`	`configs.put(ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG, 2000);`
`192`	`192`	`return new DefaultKafkaConsumerFactory<>(configs);`
`193`	`193`	`}`