https://pushtechnology.medium.com/new-kafka-adapter-connect-diffusion-6-6-with-apache-kafka-6aec2daf969a