Fix RetryingDeserializerTests after previous refactoring

artembilan · artembilan · commit 8ee6b5bc26b5 · 2024-02-15T17:25:59.000-05:00
diff --git a/spring-kafka/src/test/java/org/springframework/kafka/support/serializer/RetryingDeserializerTests.java b/spring-kafka/src/test/java/org/springframework/kafka/support/serializer/RetryingDeserializerTests.java
@@ -46,7 +46,7 @@ void basicRetryingDeserializer() {
 		AtomicInteger n = new AtomicInteger();
 		Deserializer<String> delegate =
 				(topic, data) -> {
-					if (n.incrementAndGet() < 2) {
+					if (n.incrementAndGet() < 3) {
 						throw new RuntimeException();
 					}
 					return new String(data);

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ void basicRetryingDeserializer() {`
`46`	`46`	`AtomicInteger n = new AtomicInteger();`
`47`	`47`	`Deserializer<String> delegate =`
`48`	`48`	`(topic, data) -> {`
`49`		`- if (n.incrementAndGet() < 2) {`
	`49`	`+ if (n.incrementAndGet() < 3) {`
`50`	`50`	`throw new RuntimeException();`
`51`	`51`	`}`
`52`	`52`	`return new String(data);`