From 9cbc42c73f85e40a6c38f652c425c5bf3b4ca014 Mon Sep 17 00:00:00 2001 From: Tim Olson Date: Wed, 1 Apr 2026 21:50:41 -0400 Subject: [PATCH] prod fixes --- deploy/k8s/dev/configs/ingestor-config.yaml | 1 - deploy/k8s/prod/configs/ingestor-config.yaml | 1 - ingestor/src/index.js | 2 +- 3 files changed, 1 insertion(+), 3 deletions(-) diff --git a/deploy/k8s/dev/configs/ingestor-config.yaml b/deploy/k8s/dev/configs/ingestor-config.yaml index 7828d101..679529f6 100644 --- a/deploy/k8s/dev/configs/ingestor-config.yaml +++ b/deploy/k8s/dev/configs/ingestor-config.yaml @@ -14,7 +14,6 @@ supported_exchanges: # Kafka configuration kafka_brokers: - kafka:9092 -kafka_topic: market-ohlc # Worker configuration max_concurrent: 10 diff --git a/deploy/k8s/prod/configs/ingestor-config.yaml b/deploy/k8s/prod/configs/ingestor-config.yaml index b8ffd162..679529f6 100644 --- a/deploy/k8s/prod/configs/ingestor-config.yaml +++ b/deploy/k8s/prod/configs/ingestor-config.yaml @@ -14,7 +14,6 @@ supported_exchanges: # Kafka configuration kafka_brokers: - kafka:9092 -kafka_topic: market-0 # Worker configuration max_concurrent: 10 diff --git a/ingestor/src/index.js b/ingestor/src/index.js index 686a9544..21e54d75 100644 --- a/ingestor/src/index.js +++ b/ingestor/src/index.js @@ -56,7 +56,7 @@ function loadConfig() { // Kafka configuration kafka_brokers: config.kafka_brokers || ['localhost:9092'], - kafka_topic: config.kafka_topic || 'market-0', + kafka_topic: 'market-ohlc', // Worker configuration max_concurrent: config.max_concurrent || 10,