Hi, I am using Kafka Connect Sink Connector to consume messages from a Kafka topic in a secure Kafka cluster. I have provided the group.id in connect-distributed.properties. I am using security.protocol as SASL_PLAINTEXT.
Here is definition of group id in connect-distributed.properties - [sa9726@clpd355 conf]$ less connect-distributed.properties |grep -i group group.id=alert In the Kafka Connect log, its picking up the group.id in the properties file - 2016-11-28 15:49:40 INFO DistributedConfig : 165 - DistributedConfig values: request.timeout.ms = 40000 retry.backoff.ms = 100