Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Checkstyle violation

Browse Source
This commit is contained in:
Artem Bilan
2021-10-26 14:10:14 -04:00
parent 00bf6aeea2
commit 053576047a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka/src/test/java/org/springframework/kafka/core/KafkaTemplateTests.java
View File

@@ -454,7 +454,7 @@ public class KafkaTemplateTests {
final CountDownLatch latch = new CountDownLatch(1);
final AtomicReference<SendResult<Integer, String>> theResult = new AtomicReference<>();
AtomicReference<String> value = new AtomicReference<>();
future.addCallback(result -> {}, (KafkaFailureCallback<Integer, String>) ex -> {
future.addCallback(result -> { }, (KafkaFailureCallback<Integer, String>) ex -> {
ProducerRecord<Integer, String> failed = ex.getFailedProducerRecord();
value.set(failed.value());
latch.countDown();