cadonna commented on a change in pull request #10529:
URL: https://github.com/apache/kafka/pull/10529#discussion_r612291115
##########
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/InternalTopicManagerTest.java
##########
@@ -153,7 +156,8 @@ public void shouldNotCreateTopicsWithEmptyInput() throws
Exception {
@Test
public void shouldOnlyRetryNotSuccessfulFuturesDuringSetup() {
- final AdminClient admin = EasyMock.createNiceMock(AdminClient.class);
+ final AdminClient admin = EasyMock.createStrictMock(AdminClient.class);
+ config.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 10_000L);
Review comment:
After this PR is merged, I will open a PR that changes also the other
usages of `Time.SYSTEM` and `createNiceMock()` since I think that would make
all tests more robust. I do not do it now because I am still working on that
code for KIP-698 and I do not want to run into too many merge conflicts.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
