LIB ---> Producer ---> Save to Redis stream

Broker ---> Read from redis stream ---> Process event ---> Save to DB