fix NPE in InternalTopicManagerTest
Reviewers: A. Sophie Blee-Goldman Luke Chen (@showuon), Bruno Cadonna Chia-Ping Tsai
@@ -153,9 +153,9 @@ public class InternalTopicManagerTest {
@Test
public void shouldOnlyRetryNotSuccessfulFuturesDuringSetup() {
- final AdminClient admin = EasyMock.createNiceMock(AdminClient.class);
+ final AdminClient admin = EasyMock.createMock(AdminClient.class);
final StreamsConfig streamsConfig = new StreamsConfig(config);
- final InternalTopicManager topicManager = new InternalTopicManager(Time.SYSTEM, admin, streamsConfig);
+ final InternalTopicManager topicManager = new InternalTopicManager(new MockTime(1L), admin, streamsConfig);
final KafkaFutureImpl<TopicMetadataAndConfig> createTopicFailFuture = new KafkaFutureImpl<>();
createTopicFailFuture.completeExceptionally(new TopicExistsException("exists"));
final KafkaFutureImpl<TopicMetadataAndConfig> createTopicSuccessfulFuture = new KafkaFutureImpl<>();
