vw_kafka_connector_topic_maps

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

Overview

Name	vw_kafka_connector_topic_maps
Type	View
Id	azure.iot_mq.vw_kafka_connector_topic_maps

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, '$.batching') as "batching",
JSON_EXTRACT(properties, '$.compression') as "compression",
JSON_EXTRACT(properties, '$.copyMqttProperties') as "copy_mqtt_properties",
JSON_EXTRACT(properties, '$.kafkaConnectorRef') as "kafka_connector_ref",
JSON_EXTRACT(properties, '$.partitionKeyProperty') as "partition_key_property",
JSON_EXTRACT(properties, '$.partitionStrategy') as "partition_strategy",
JSON_EXTRACT(properties, '$.routes') as "routes",
JSON_EXTRACT(properties, '$.provisioningState') as "provisioning_state",
subscriptionId,
resourceGroupName,
mqName,
kafkaConnectorName,
topicMapName
FROM azure.iot_mq.kafka_connector_topic_maps
WHERE subscriptionId = 'replace-me' AND resourceGroupName = 'replace-me' AND mqName = 'replace-me' AND kafkaConnectorName = 'replace-me';

Postgres

SELECT
location as location,
extendedLocation as extended_location,
tags as tags,
json_extract_path_text(properties, '$.batching') as "batching",
json_extract_path_text(properties, '$.compression') as "compression",
json_extract_path_text(properties, '$.copyMqttProperties') as "copy_mqtt_properties",
json_extract_path_text(properties, '$.kafkaConnectorRef') as "kafka_connector_ref",
json_extract_path_text(properties, '$.partitionKeyProperty') as "partition_key_property",
json_extract_path_text(properties, '$.partitionStrategy') as "partition_strategy",
json_extract_path_text(properties, '$.routes') as "routes",
json_extract_path_text(properties, '$.provisioningState') as "provisioning_state",
subscriptionId,
resourceGroupName,
mqName,
kafkaConnectorName,
topicMapName
FROM azure.iot_mq.kafka_connector_topic_maps
WHERE subscriptionId = 'replace-me' AND resourceGroupName = 'replace-me' AND mqName = 'replace-me' AND kafkaConnectorName = 'replace-me';