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 MP_MESSAGING_INCOMING_STOCKTRADER_TOPIC which maps to kafka.historyTopic.
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
MP_MESSAGING_INCOMING_STOCKTRADER_TOPICwhich maps tokafka.historyTopic.