Connecting Pyflink DDL to Azure Eventhubs using Kafka connector

Mon, 08 Feb 2021 10:46:57 -0800 

I'm trying to read data from my eventhub in Azure, but i end up with the
Flink error message 'findAndCreateTableSource failed'

using Flink 1.13-Snapshot

source_ddl = f"""CREATE TABLE dms_source(
                                x_value VARCHAR
                         ) WITH (
                          'connector.type' = 'Kafka',
                          'connector.version' = 'universal',
                          'connector.partition' = '0',
                          'connector.sasl.jaas.config'=
'org.apache.kafka.common.security.plain.PlainLoginModule required
username="$ConnectionString"
password="Endpoint=sb://**EVEN_HUB_NAME**.servicebus.windows.net/;SharedAccessKeyName=**KEY_
NAME**;SharedAccessKey=***PRIMARY_KEY***;EntityPath=**EVENT_HUB_INSTANCE_NAME**";',
                          'connector.sasl.mechanism' = 'PLAIN',
                          'connector.security.protocol' = 'SASL_SSL',
                          'connector.properties.bootstrap.servers' =
'**EVEN_HUB_NAME**.servicebus.windows.net:9093',
                          'connector.properties.group.id' = '$Default',
                          'connector.startup-mode' = 'latest-offset',
                          'format.type' = 'json')
                        """

Any tips on how to debug this?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to