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?