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

GH-1621: More back-ported test fixes

Browse Source
This commit is contained in:
Gary Russell
2020-11-12 16:44:40 -05:00
parent 21f511b1a3
commit 724ac8a162
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-kafka/src/test/java/org/springframework/kafka/listener/ManualNackRecordTxTests.java
View File

@@ -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" })