updated: now I have resolved the connection issue (due to wrong arguments passed to sasl).
but I meat another problem: 22/07/28 20:17:48 ERROR MicroBatchExecution: Query [id = 2a3bd87a-3a9f-4e54-a697-3d67cef77230, runId = 11c7ca0d-1bd9-4499-a613-6b6e8e8735ca] terminated with error org.apache.kafka.common.errors.InvalidTopicException: Invalid topics: [xxxxx] 22/07/28 20:17:48 DEBUG StateStoreCoordinator: Deactivating instances related to checkpoint location 11c7ca0d-1bd9-4499-a613-6b6e8e8735ca: Exception in thread "main" org.apache.spark.sql.streaming.StreamingQueryException: Invalid topics: [xxxxx] my topic name is just a regular string like "abc_def". Can you help? --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org
