Capturing Edgex system events using Fluent-bit MQTT Input plugin

[kuldeepmarker-eaton]

HI All,

I have been trying to capture system events of Edgex (edgex/system-events) using Fluent-bit. The Edgex publishes the system events on message bus and the messagebus type is MQTT. So I considered to use fluent-bit MQTT as Input plugin to capture these events.

I have face challenge here and I would like to describe them below.

1. The MQTT Input plugin of fluent-bit behaves as a server so the system events published on message bus is not getting reached to fluent-bit.

2. The MQTT Input plugin does not have any options to subscribe to required topics.

Can anyone suggest whether the way I am trying to forward system events to fluent-bit is possible or is there some other way to achieve the same.

Thanks,
Kuldeep