Currently in kafka consumers we do not have support for authentication/authorization and normal TLS. This change is to support this feature.