function to consume kafka events from a given list of topics.

function to producer.

sent to all users.

all activity events(events that will be sent to all use3rs) published to this topic.

chat is inserted in DB.

all chat messages will be published to this topic.

file is saved to S3 bucket.

all file messages will be published to this topic.

sent only to a specific user.

all notification events(event meant for any specific user) published to this topic.