From b9d365853292a6475577436cac1b8bf93181a3ba Mon Sep 17 00:00:00 2001 From: a1exsh Date: Tue, 17 Jan 2023 13:13:14 +0100 Subject: [PATCH] Don't create extra KafkaLocationManager (#1489) Seems like an oversight that we were creating two of them per topic repository. --- .../org/zalando/nakadi/repository/KafkaRepositoryCreator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core-common/src/main/java/org/zalando/nakadi/repository/KafkaRepositoryCreator.java b/core-common/src/main/java/org/zalando/nakadi/repository/KafkaRepositoryCreator.java index b96cf0ba13..b342a97447 100644 --- a/core-common/src/main/java/org/zalando/nakadi/repository/KafkaRepositoryCreator.java +++ b/core-common/src/main/java/org/zalando/nakadi/repository/KafkaRepositoryCreator.java @@ -64,7 +64,7 @@ public TopicRepository createTopicRepository(final Storage storage) throws Topic zookeeperSettings.getZkConnectionTimeoutMs(), nakadiSettings); final KafkaLocationManager kafkaLocationManager = new KafkaLocationManager(zooKeeperHolder, kafkaSettings); - final KafkaFactory kafkaFactory = new KafkaFactory(new KafkaLocationManager(zooKeeperHolder, kafkaSettings), + final KafkaFactory kafkaFactory = new KafkaFactory(kafkaLocationManager, nakadiSettings.getKafkaActiveProducersCount()); final KafkaZookeeper zk = new KafkaZookeeper(zooKeeperHolder, objectMapper); final KafkaTopicRepository kafkaTopicRepository =