update to hardcode kafka cluster