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 9566325 commit b6e6502Copy full SHA for b6e6502
spring-kafka/src/test/java/org/springframework/kafka/listener/FallbackBatchErrorHandlerTests.java
@@ -235,7 +235,9 @@ void resetRetryingFlagOnExceptionFromRetryBatch() {
235
private boolean getRetryingFieldValue(FallbackBatchErrorHandler errorHandler) {
236
Field field = ReflectionUtils.findField(FallbackBatchErrorHandler.class, "retrying");
237
ReflectionUtils.makeAccessible(field);
238
+ @SuppressWarnings("unchecked")
239
ThreadLocal<Boolean> value = (ThreadLocal<Boolean>) ReflectionUtils.getField(field, errorHandler);
240
return value.get();
241
}
242
+
243
0 commit comments