vw_kafka_connectors

Creates, updates, deletes, gets or lists a vw_kafka_connectors resource.

Overview

Name	vw_kafka_connectors
Type	View
Id	azure.iot_mq.vw_kafka_connectors

Fields

See the SQL Definition (view DDL) for fields returned by this view.

SQL Definition

Sqlite3

SELECT
location as location,
extendedLocation as extended_location,
tags as tags,
JSON_EXTRACT(properties, '$.clientIdPrefix') as "client_id_prefix",
JSON_EXTRACT(properties, '$.image') as "image",
JSON_EXTRACT(properties, '$.instances') as "instances",
JSON_EXTRACT(properties, '$.kafkaConnection') as "kafka_connection",
JSON_EXTRACT(properties, '$.localBrokerConnection') as "local_broker_connection",
JSON_EXTRACT(properties, '$.logLevel') as "log_level",
JSON_EXTRACT(properties, '$.nodeTolerations') as "node_tolerations",
JSON_EXTRACT(properties, '$.provisioningState') as "provisioning_state",
subscriptionId,
resourceGroupName,
mqName,
kafkaConnectorName
FROM azure.iot_mq.kafka_connectors
WHERE subscriptionId = 'replace-me' AND resourceGroupName = 'replace-me' AND mqName = 'replace-me';

Postgres

SELECT
location as location,
extendedLocation as extended_location,
tags as tags,
json_extract_path_text(properties, '$.clientIdPrefix') as "client_id_prefix",
json_extract_path_text(properties, '$.image') as "image",
json_extract_path_text(properties, '$.instances') as "instances",
json_extract_path_text(properties, '$.kafkaConnection') as "kafka_connection",
json_extract_path_text(properties, '$.localBrokerConnection') as "local_broker_connection",
json_extract_path_text(properties, '$.logLevel') as "log_level",
json_extract_path_text(properties, '$.nodeTolerations') as "node_tolerations",
json_extract_path_text(properties, '$.provisioningState') as "provisioning_state",
subscriptionId,
resourceGroupName,
mqName,
kafkaConnectorName
FROM azure.iot_mq.kafka_connectors
WHERE subscriptionId = 'replace-me' AND resourceGroupName = 'replace-me' AND mqName = 'replace-me';