File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
spring-kafka/src/test/java/org/springframework/kafka/listener Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change 4141import java .util .concurrent .atomic .AtomicInteger ;
4242
4343import org .apache .kafka .clients .consumer .Consumer ;
44- import org .apache .kafka .clients .consumer .ConsumerGroupMetadata ;
4544import org .apache .kafka .clients .consumer .ConsumerRebalanceListener ;
4645import org .apache .kafka .clients .consumer .ConsumerRecord ;
4746import org .apache .kafka .clients .consumer .ConsumerRecords ;
@@ -212,7 +211,6 @@ public Consumer consumer() {
212211 this .closeLatch .countDown ();
213212 return null ;
214213 }).given (consumer ).close ();
215- given (consumer .groupMetadata ()).willReturn (mock (ConsumerGroupMetadata .class ));
216214 return consumer ;
217215 }
218216
@@ -236,10 +234,10 @@ ProducerFactory pf() {
236234 return pf ;
237235 }
238236
239- @ SuppressWarnings ("rawtypes" )
237+ @ SuppressWarnings ({ "rawtypes" , "unchecked" } )
240238 @ Bean
241239 KafkaTransactionManager tm () {
242- return new KafkaTransactionManager <> (pf ());
240+ return new KafkaTransactionManager (pf ());
243241 }
244242
245243 @ SuppressWarnings ({ "rawtypes" , "unchecked" })
You can’t perform that action at this time.
0 commit comments