Change the kafka producer test