root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

MINOR: Address occasional UnnecessaryStubbingException in StreamThreadTest (#15134) 

Reviewers: Divij Vaidya <diviv@amazon.com>, Lucas Brutschy <lbrutschy@confluent.io>
This commit is contained in:
Christo Lolov 2024-01-10 13:39:59 +00:00 committed by GitHub
parent ee96935c60
commit 5a0a4c5a54
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
View File

@ -774,7 +774,7 @@ public class StreamThreadTest {
mockTime
);
when(consumer.poll(any())).thenReturn(ConsumerRecords.empty());
lenient().when(consumer.poll(any())).thenReturn(ConsumerRecords.empty());
final ConsumerGroupMetadata consumerGroupMetadata = mock(ConsumerGroupMetadata.class);
when(consumer.groupMetadata()).thenReturn(consumerGroupMetadata);
when(consumerGroupMetadata.groupInstanceId()).thenReturn(Optional.empty());