Don't create extra KafkaLocationManager (#1489)

Seems like an oversight that we were creating two of them per topic repository.
zalando · Jan 17, 2023 · b9d3658 · b9d3658
1 parent e862d6a
commit b9d3658
Showing 1 changed file with 1 addition and 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
@@ -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 =