Skip to main content

kafka_connectors

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

Overview

Namekafka_connectors
TypeResource
Idazure.iot_mq.kafka_connectors

Fields

The following fields are returned by SELECT queries:

Azure operation completed successfully.

NameDatatypeDescription
extendedLocationobjectExtended Location
locationstringThe geo-location where the resource lives
propertiesobjectThe resource-specific properties for this resource.
tagsobjectResource tags.

Methods

The following methods are available for this resource:

NameAccessible byRequired ParamsOptional ParamsDescription
getselectsubscriptionId, resourceGroupName, mqName, kafkaConnectorNameGet a KafkaConnectorResource
list_by_mq_resourceselectsubscriptionId, resourceGroupName, mqNameList KafkaConnectorResource resources by MqResource
create_or_updateinsertsubscriptionId, resourceGroupName, mqName, kafkaConnectorName, data__extendedLocationCreate a KafkaConnectorResource
updateupdatesubscriptionId, resourceGroupName, mqName, kafkaConnectorNameUpdate a KafkaConnectorResource
deletedeletesubscriptionId, resourceGroupName, mqName, kafkaConnectorNameDelete a KafkaConnectorResource

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

NameDatatypeDescription
kafkaConnectorNamestringName of MQ kafkaConnector resource
mqNamestringName of MQ resource
resourceGroupNamestringThe name of the resource group. The name is case insensitive.
subscriptionIdstringThe ID of the target subscription.

SELECT examples

Get a KafkaConnectorResource

SELECT
extendedLocation,
location,
properties,
tags
FROM azure.iot_mq.kafka_connectors
WHERE subscriptionId = '{{ subscriptionId }}' -- required
AND resourceGroupName = '{{ resourceGroupName }}' -- required
AND mqName = '{{ mqName }}' -- required
AND kafkaConnectorName = '{{ kafkaConnectorName }}' -- required
;

INSERT examples

Create a KafkaConnectorResource

INSERT INTO azure.iot_mq.kafka_connectors (
data__properties,
data__extendedLocation,
data__tags,
data__location,
subscriptionId,
resourceGroupName,
mqName,
kafkaConnectorName
)
SELECT
'{{ properties }}',
'{{ extendedLocation }}' /* required */,
'{{ tags }}',
'{{ location }}',
'{{ subscriptionId }}',
'{{ resourceGroupName }}',
'{{ mqName }}',
'{{ kafkaConnectorName }}'
RETURNING
extendedLocation,
location,
properties,
tags
;

UPDATE examples

Update a KafkaConnectorResource

UPDATE azure.iot_mq.kafka_connectors
SET
data__tags = '{{ tags }}',
data__properties = '{{ properties }}'
WHERE
subscriptionId = '{{ subscriptionId }}' --required
AND resourceGroupName = '{{ resourceGroupName }}' --required
AND mqName = '{{ mqName }}' --required
AND kafkaConnectorName = '{{ kafkaConnectorName }}' --required
RETURNING
extendedLocation,
location,
properties,
tags;

DELETE examples

Delete a KafkaConnectorResource

DELETE FROM azure.iot_mq.kafka_connectors
WHERE subscriptionId = '{{ subscriptionId }}' --required
AND resourceGroupName = '{{ resourceGroupName }}' --required
AND mqName = '{{ mqName }}' --required
AND kafkaConnectorName = '{{ kafkaConnectorName }}' --required
;