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

Restore generic args for anonymous classes

Browse Source 
https://build.spring.io/browse/SK-K25X-123/
This commit is contained in:
Artem Bilan
2021-10-26 14:06:13 -04:00
parent c4787fc892
commit 38390e893d
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -102,7 +102,8 @@ public class KafkaTemplateTests {
private static Consumer<Integer, String> consumer;
private static final ProducerFactory.Listener<String, String> noopListener = new ProducerFactory.Listener<>() {
private static final ProducerFactory.Listener<String, String> noopListener =
new ProducerFactory.Listener<String, String>() {
@Override
public void producerAdded(String id, Producer<String, String> producer) {
@@ -357,7 +358,7 @@ public class KafkaTemplateTests {
template.flush();
final CountDownLatch latch = new CountDownLatch(1);
final AtomicReference<SendResult<Integer, String>> theResult = new AtomicReference<>();
future.addCallback(new ListenableFutureCallback<>() {
future.addCallback(new ListenableFutureCallback<SendResult<Integer, String>>() {
@Override
public void onSuccess(SendResult<Integer, String> result) {
@@ -391,7 +392,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(new KafkaSendCallback<>() {
future.addCallback(new KafkaSendCallback<Integer, String>() {
@Override
public void onSuccess(SendResult<Integer, String> result) {
@@ -499,7 +500,7 @@ public class KafkaTemplateTests {
@Test
void testConfigOverridesWithCustomProducerFactory() {
Map<String, Object> senderProps = KafkaTestUtils.producerProps(embeddedKafka);
ProducerFactory<String, String> pf = new ProducerFactory<>() {
ProducerFactory<String, String> pf = new ProducerFactory<String, String>() {
@Override
public Producer<String, String> createProducer() {

1
spring-kafka/src/test/java/org/springframework/kafka/core/reactive/ReactiveKafkaProducerTemplateIntegrationTests.java
View File

@@ -408,7 +408,6 @@ public class ReactiveKafkaProducerTemplateIntegrationTests {
Mono<Void> sendWithFlushMono = reactiveKafkaProducerTemplate
.send(Mono.just(SenderRecord
.create(new ProducerRecord<>(REACTIVE_INT_KEY_TOPIC, DEFAULT_KEY, DEFAULT_VALUE), null)))
.then(reactiveKafkaProducerTemplate.flush())
.then();
StepVerifier.create(sendWithFlushMono)