Cannot get source metadata for pipeline Batch starting with new consumer

CREATE PIPELINE kafka_kerberos_no_ssl

AS LOAD DATA KAFKA ‘host.com:9094/MEMSQL_SAMPLE

CONFIG '{“security.protocol”: “sasl_plaintext”,

“sasl.mechanism”: “plain”,

“sasl.kerberos.service.name”: “kafka”,

“sasl.kerberos.keytab”: “service.keytab”}’

INTO table test3;

while creating pipeline getting below error!

ERROR 1933 ER_EXTRACTOR_EXTRACTOR_GET_LATEST_OFFSETS: Cannot get source metadata for pipeline. Stderr: 2020-11-19 09:55:46.001 Batch starting with new consumer.

Any one can help?