We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 439f2a5 commit 7d22fc0Copy full SHA for 7d22fc0
spring-kafka/src/test/java/org/springframework/kafka/listener/TransactionalContainerTests.java
@@ -186,7 +186,7 @@ public void testConsumeAndProduceTransactionRollback() throws Exception {
186
return null;
187
}).given(consumer).seek(any(), anyLong());
188
ConsumerFactory cf = mock(ConsumerFactory.class);
189
- willReturn(consumer).given(cf).createConsumer("group", "");
+ willReturn(consumer).given(cf).createConsumer("group", null);
190
Producer producer = mock(Producer.class);
191
final CountDownLatch closeLatch = new CountDownLatch(1);
192
willAnswer(i -> {
0 commit comments