The current implementation of portfolio uses a config map entry from kafka.historyTopic which is mapped to the environment variable KAFKA_HISTORY_TOPIC to determine which Kafka topic to forward trade history to. In the current implementation the topic is decided by KAFKA_TOPIC which is not currently used which means we use the default topic, stocktrader.
Let's update portfolio to use KAFKA_HISTORY_TOPIC.
jwalcorn
commented
2 years ago
The current implementation of portfolio uses a config map entry from
kafka.historyTopicwhich is mapped to the environment variableKAFKA_HISTORY_TOPICto determine which Kafka topic to forward trade history to. In the current implementation the topic is decided byKAFKA_TOPICwhich is not currently used which means we use the default topic,stocktrader.Let's update portfolio to use
KAFKA_HISTORY_TOPIC.