Delete topic

dydxprotocol · Sep 6, 2024 · b5095b0 · b5095b0
1 parent 0c7327a
commit b5095b0
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/indexer/packages/kafka/src/types.ts b/indexer/packages/kafka/src/types.ts
@@ -11,7 +11,7 @@ export enum KafkaTopics {
   TO_ENDER = 'to-ender',
   TO_VULCAN = 'to-vulcan',
   TO_WEBSOCKETS_ORDERBOOKS = 'to-websockets-orderbooks',
-  TO_WEBSOCKETS_SUBACCOUNTS = 'to-websockets-subaccounts-1',
+  TO_WEBSOCKETS_SUBACCOUNTS = 'to-websockets-subaccounts',
   TO_WEBSOCKETS_TRADES = 'to-websockets-trades',
   TO_WEBSOCKETS_MARKETS = 'to-websockets-markets',
   TO_WEBSOCKETS_CANDLES = 'to-websockets-candles',

diff --git a/indexer/services/bazooka/src/index.ts b/indexer/services/bazooka/src/index.ts
@@ -195,6 +195,14 @@ async function createKafkaTopics(
 ): Promise<void> {
   const kafkaTopicsToCreate: KafkaTopics[] = [];
 
+  await admin.deleteTopics({
+    topics: [KafkaTopics.TO_WEBSOCKETS_SUBACCOUNTS],
+  })
+  logger.info({
+    at: 'index#createKafkaTopics',
+    message: `Deleted ${KafkaTopics.TO_WEBSOCKETS_SUBACCOUNTS}`,
+  });
+
   _.forEach(KAFKA_TOPICS, (kafkaTopic: KafkaTopics) => {
     if (_.includes(existingKafkaTopics, kafkaTopic)) {
       logger.info({