Come hai integrato esattamente il client Kafka nel progetto, come l'hai usato?