State_changed events not flowing via mqtt_eventstream - why?

Hi all,
I’m trying to configure 2 HA instances as master/slave. My goal is:

  1. master will send commands that slave will consume
  2. slave will send states that master will consume and display in UI

Configuration code used:

#Master conf:
mqtt_eventstream:
  publish_topic: ha/commands
  subscribe_topic: ha/states
  ignore_event:
    - state_changed
#Slave conf:
mqtt_eventstream:
  publish_topic: ha/states
  subscribe_topic: ha/commands
  ignore_event:
    - call_service

I tried enabling logger for this component but it looks this component is not importing the logging module so nothing relevant is displayed when raising level to debug.

In the slave I can see the state_changed events being generated locally (using Developer).

Using MQTT Explorer I don’t see any event created in the ha/states topic, however I see some in the ha/commands.

Any idea about why state_changed events are not sent to mqtt using eventstream? Has anyone made it work that could share some config example?
Any other troubleshooting suggestion is very welcomed.

Thanks!

I found my mistake. There was a port mismatch. Mosquitto was listening on one port and I configured a different port on the slave HA instance so it was sending data to nowhere.