feat: implement asynchronous Kafka and Redis pub/sub mechanisms with message handling 4390951 npv2k1 commited on Jul 26, 2025