When we are creating Kafka pipeline in SingleStore we are getting the following error message. please help us
Error message
-
CREATE PIPELINE abcd AS LOAD DATA KAFKA ‘XXXXXXXXXXXx"/XXXXX’ skip constraint errors INTO table kafka_gup_t
ERROR 1933 ER_EXTRACTOR_EXTRACTOR_GET_LATEST_OFFSETS: Cannot get source metadata for pipeline. Failed to get watermark offsets from Kafka with error Broker: Leader not available. -
ERROR 1934 ER_EXTRACTOR_EXTRACTOR_EXTRACT: Leaf Error (ip-10-45-76-188.ec2.internal:3306): Cannot extract data for pipeline. Could not stream message (Are the Kafka brokers reachable from this node?)
Note: We were able to telnet and connect