From 0c7327ab7a8d483a32e3bb399d109ff24e4f6d56 Mon Sep 17 00:00:00 2001 From: Roy Li Date: Thu, 5 Sep 2024 16:55:13 -0400 Subject: [PATCH] change topic --- indexer/packages/kafka/src/types.ts | 2 +- indexer/services/bazooka/src/index.ts | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/indexer/packages/kafka/src/types.ts b/indexer/packages/kafka/src/types.ts index 27b0b3e993..88ad872120 100644 --- 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', + TO_WEBSOCKETS_SUBACCOUNTS = 'to-websockets-subaccounts-1', 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 index 3239ffd691..d353397fe8 100644 --- a/indexer/services/bazooka/src/index.ts +++ b/indexer/services/bazooka/src/index.ts @@ -27,7 +27,7 @@ const KAFKA_TOPICS_TO_PARTITIONS: { [key in KafkaTopics]: number } = { [KafkaTopics.TO_ENDER]: 1, [KafkaTopics.TO_VULCAN]: 60, [KafkaTopics.TO_WEBSOCKETS_ORDERBOOKS]: 1, - [KafkaTopics.TO_WEBSOCKETS_SUBACCOUNTS]: 30, + [KafkaTopics.TO_WEBSOCKETS_SUBACCOUNTS]: 3, [KafkaTopics.TO_WEBSOCKETS_TRADES]: 1, [KafkaTopics.TO_WEBSOCKETS_MARKETS]: 1, [KafkaTopics.TO_WEBSOCKETS_CANDLES]: 1,