removed async from kafka example