kafka consumer test fixed