Increase max.wait in BatchIndividualRecordObservationTests

artembilan · artembilan · commit 02fc7d1eb27e · 2025-09-29T09:45:38.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
@@ -188,7 +188,7 @@ ProducerFactory<Integer, String> producerFactory(EmbeddedKafkaBroker broker) {
 		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_MAX_WAIT_MS_CONFIG, 1000);
+			configs.put(ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG, 2000);
 			return new DefaultKafkaConsumerFactory<>(configs);
 		}
 

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