Adds KAFKA_TAG env var and sets default as 2.11-1.0.2