Bring back @Test to MessageDrivenAdapterTests.testInboundBatch

artembilan · spring-builds · commit 4b2701feae0f · 2026-03-30T16:21:12.000Z
Looks like `@RetryingTest` cannot work with JUnit argument resolver (cherry picked from commit 9de40b2)
diff --git a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageDrivenAdapterTests.java
@@ -400,7 +400,7 @@ protected boolean doSend(Message<?> message, long timeout) {
 		pf.reset();
 	}
 
-	@RetryingTest(10)
+	@Test
 	void testInboundBatch(EmbeddedKafkaBroker embeddedKafka) throws Exception {
 		Map<String, Object> props = KafkaTestUtils.consumerProps(embeddedKafka, "test2", true);
 		props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

Original file line number	Diff line number	Diff line change
`@@ -400,7 +400,7 @@ protected boolean doSend(Message<?> message, long timeout) {`
`400`	`400`	`pf.reset();`
`401`	`401`	`}`
`402`	`402`
`403`		`- @RetryingTest(10)`
	`403`	`+ @Test`
`404`	`404`	`void testInboundBatch(EmbeddedKafkaBroker embeddedKafka) throws Exception {`
`405`	`405`	`Map<String, Object> props = KafkaTestUtils.consumerProps(embeddedKafka, "test2", true);`
`406`	`406`	`props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");`