You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
enable publishing with qos "consume exactly once": kafka: consumer groups, mqtt: implement worker queues at broker and/or socket side;
implement (re-)connection handling: currently using kafka and mqtt inbuilt configs
persistence idea: save and load sockets including all props e.g. from litedb; possible reasons: not everything can be loaded from config (e.g. queued jobs, subscribed actions).
Broker:
mqtt: add logging (e.g. using serilog)
kafka: check possibility to intercept
kafka: implement router-client to simulate mqtt topic routing
Sockets:
Broker:
DemoApp(s):