diff --git a/indexer/packages/kafka/src/types.ts b/indexer/packages/kafka/src/types.ts index 27b0b3e9933..88ad872120b 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 3239ffd6915..d353397fe8e 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,