Fix bug in clearing topics (backport #2202) (#2211)

Co-authored-by: roy-dydx <[email protected]>
dydxprotocol · Sep 5, 2024 · 386f64d · 386f64d
1 parent 8164874
commit 386f64d
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/indexer/services/bazooka/src/index.ts b/indexer/services/bazooka/src/index.ts
@@ -241,6 +241,10 @@ async function partitionKafkaTopics(): Promise<void> {
     });
     if (topicMetadata.topics.length === 1) {
       if (topicMetadata.topics[0].partitions.length !== KAFKA_TOPICS_TO_PARTITIONS[kafkaTopic]) {
+        logger.info({
+          at: 'index#partitionKafkaTopics',
+          message: `Setting topic ${kafkaTopic} to ${KAFKA_TOPICS_TO_PARTITIONS[kafkaTopic]} partitions`,
+        });
         await admin.createPartitions({
           validateOnly: false,
           topicPartitions: [{
@@ -249,7 +253,7 @@ async function partitionKafkaTopics(): Promise<void> {
           }],
         });
         logger.info({
-          at: 'index#createKafka  Topics',
+          at: 'index#partitionKafkaTopics',
           message: `Successfully set topic ${kafkaTopic} to ${KAFKA_TOPICS_TO_PARTITIONS[kafkaTopic]} partitions`,
         });
       }
@@ -261,7 +265,7 @@ async function clearKafkaTopics(
   existingKafkaTopics: string[],
 ): Promise<void> {
   await Promise.all(
-    _.map(KAFKA_TOPICS_TO_PARTITIONS,
+    _.map(KAFKA_TOPICS,
       clearKafkaTopic.bind(null,
         1,
         config.CLEAR_KAFKA_TOPIC_RETRY_MS,