Netflix conductor integration with queue

[Raju_Rawat]

How do we integrate kafka or any other queuq to netflix conductor to consume messages?