JavaAPISuite new uses the new kafkaSteam API