We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2eacf7a commit 781e726Copy full SHA for 781e726
spring-kafka/src/test/java/org/springframework/kafka/listener/FallbackBatchErrorHandlerTests.java
@@ -238,7 +238,9 @@ void resetRetryingFlagOnExceptionFromRetryBatch() {
238
private boolean getRetryingFieldValue(FallbackBatchErrorHandler errorHandler) {
239
Field field = ReflectionUtils.findField(FallbackBatchErrorHandler.class, "retrying");
240
ReflectionUtils.makeAccessible(field);
241
+ @SuppressWarnings("unchecked")
242
ThreadLocal<Boolean> value = (ThreadLocal<Boolean>) ReflectionUtils.getField(field, errorHandler);
243
return value.get();
244
}
245
+
246
0 commit comments