From 724ac8a1622e3488686e5a5d06bd2bb392edc201 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Thu, 12 Nov 2020 16:44:40 -0500 Subject: [PATCH] GH-1621: More back-ported test fixes --- .../kafka/listener/ManualNackRecordTxTests.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/spring-kafka/src/test/java/org/springframework/kafka/listener/ManualNackRecordTxTests.java b/spring-kafka/src/test/java/org/springframework/kafka/listener/ManualNackRecordTxTests.java index 18e5ed0c..0cb68c28 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/listener/ManualNackRecordTxTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/listener/ManualNackRecordTxTests.java @@ -41,7 +41,6 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.apache.kafka.clients.consumer.Consumer; -import org.apache.kafka.clients.consumer.ConsumerGroupMetadata; import org.apache.kafka.clients.consumer.ConsumerRebalanceListener; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; @@ -212,7 +211,6 @@ public class ManualNackRecordTxTests { this.closeLatch.countDown(); return null; }).given(consumer).close(); - given(consumer.groupMetadata()).willReturn(mock(ConsumerGroupMetadata.class)); return consumer; } @@ -236,10 +234,10 @@ public class ManualNackRecordTxTests { return pf; } - @SuppressWarnings("rawtypes") + @SuppressWarnings({ "rawtypes", "unchecked" }) @Bean KafkaTransactionManager tm() { - return new KafkaTransactionManager<>(pf()); + return new KafkaTransactionManager(pf()); } @SuppressWarnings({ "rawtypes", "unchecked" })