How to implement point to point messaging system using kafka in lagom

I want to implement a queue system for sending bulk mail and I want to use kafka .