Merge "Added support for using oauth token for Kafka"