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,