Change the Kafka Service Test
Add verification with mock producer in test