Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
# Esempi di utilizzo di Amazon MSK AWS CLI
I seguenti esempi di codice mostrano come eseguire azioni e implementare scenari comuni utilizzando AWS Command Line Interface con Amazon MSK.
Le *azioni* sono estratti di codice da programmi più grandi e devono essere eseguite nel contesto. Sebbene le azioni mostrino come richiamare le singole funzioni del servizio, è possibile visualizzarle contestualizzate negli scenari correlati.
Ogni esempio include un link al codice sorgente completo, in cui vengono fornite le istruzioni su come configurare ed eseguire il codice nel contesto.
**Topics**
+ [Azioni](#actions)
## Azioni
### `create-cluster`
Il seguente esempio di codice mostra come usare`create-cluster`.
**AWS CLI**
**Come creare un cluster Amazon MSK**
L’esempio `create-cluster` seguente crea un cluster MSK denominato `MessagingCluster` con tre nodi broker. Un file JSON denominato `brokernodegroupinfo.json` specifica le tre sottoreti su cui desideri che Amazon MSK distribuisca i nodi del broker. Questo esempio non specifica il livello di monitoraggio, quindi il cluster ottiene il livello `DEFAULT`.
```
aws kafka create-cluster \
--cluster-name "MessagingCluster" \
--broker-node-group-info file://brokernodegroupinfo.json \
--kafka-version "2.2.1" \
--number-of-broker-nodes 3
```
Contenuto di `brokernodegroupinfo.json`:
```
{
"InstanceType": "kafka.m5.xlarge",
"BrokerAZDistribution": "DEFAULT",
"ClientSubnets": [
"subnet-0123456789111abcd",
"subnet-0123456789222abcd",
"subnet-0123456789333abcd"
]
}
```
Output:
```
{
"ClusterArn": "arn:aws:kafka:us-west-2:123456789012:cluster/MessagingCluster/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2",
"ClusterName": "MessagingCluster",
"State": "CREATING"
}
```
Per ulteriori informazioni, consulta [Creare un cluster Amazon MSK](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-cluster.html) nello *Streaming gestito da Amazon per Apache Kafka (Amazon MSK)*.
+ Per i dettagli sull'API, consulta [CreateCluster AWS CLI](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/create-cluster.html)*Command Reference*.
### `create-configuration`
Il seguente esempio di codice mostra come utilizzare`create-configuration`.
**AWS CLI**
**Come creare una configurazione Amazon MSK personalizzata**
L’esempio `create-configuration` seguente crea una configurazione MSK personalizzata con le proprietà del server specificate nel file di input.
```
aws kafka create-configuration \
--name "CustomConfiguration" \
--description "Topic autocreation enabled; Apache ZooKeeper timeout 2000 ms; Log rolling 604800000 ms." \
--kafka-versions "2.2.1" \
--server-properties file://configuration.txt
```
Contenuto di `configuration.txt`:
```
auto.create.topics.enable = true
zookeeper.connection.timeout.ms = 2000
log.roll.ms = 604800000
```
Questo comando non produce alcun output. Output:
```
{
"Arn": "arn:aws:kafka:us-west-2:123456789012:configuration/CustomConfiguration/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2",
"CreationTime": "2019-10-09T15:26:05.548Z",
"LatestRevision":
{
"CreationTime": "2019-10-09T15:26:05.548Z",
"Description": "Topic autocreation enabled; Apache ZooKeeper timeout 2000 ms; Log rolling 604800000 ms.",
"Revision": 1
},
"Name": "CustomConfiguration"
}
```
Per ulteriori informazioni, consulta [Operazioni di configurazione di Amazon MSK](https://docs.aws.amazon.com/msk/latest/developerguide/msk-configuration-operations.html) nella *Guida per gli sviluppatori dello Streaming gestito da Amazon per Apache Kafka (Amazon MSK)*.
+ Per i dettagli sull'API, consulta [CreateConfiguration AWS CLI](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/create-configuration.html)*Command Reference*.
### `describe-cluster`
Il seguente esempio di codice mostra come utilizzare`describe-cluster`.
**AWS CLI**
**Come descrivere un cluster**
L’esempio `describe-cluster` seguente descrive un cluster Amazon MSK.
```
aws kafka describe-cluster \
--cluster-arn arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5
```
Output:
```
{
"ClusterInfo": {
"BrokerNodeGroupInfo": {
"BrokerAZDistribution": "DEFAULT",
"ClientSubnets": [
"subnet-cbfff283",
"subnet-6746046b"
],
"InstanceType": "kafka.m5.large",
"SecurityGroups": [
"sg-f839b688"
],
"StorageInfo": {
"EbsStorageInfo": {
"VolumeSize": 100
}
}
},
"ClusterArn": "arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5",
"ClusterName": "demo-cluster-1",
"CreationTime": "2020-07-09T02:31:36.223000+00:00",
"CurrentBrokerSoftwareInfo": {
"KafkaVersion": "2.2.1"
},
"CurrentVersion": "K3AEGXETSR30VB",
"EncryptionInfo": {
"EncryptionAtRest": {
"DataVolumeKMSKeyId": "arn:aws:kms:us-east-1:123456789012:key/a7ca56d5-0768-4b64-a670-339a9fbef81c"
},
"EncryptionInTransit": {
"ClientBroker": "TLS_PLAINTEXT",
"InCluster": true
}
},
"EnhancedMonitoring": "DEFAULT",
"OpenMonitoring": {
"Prometheus": {
"JmxExporter": {
"EnabledInBroker": false
},
"NodeExporter": {
"EnabledInBroker": false
}
}
},
"NumberOfBrokerNodes": 2,
"State": "ACTIVE",
"Tags": {},
"ZookeeperConnectString": "z-2.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:2181,z-1.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:2181,z-3.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:2181"
}
}
```
Per ulteriori informazioni, consulta [Elencazione dei cluster Amazon MSK](https://docs.aws.amazon.com/msk/latest/developerguide/msk-list-clusters.html) nella *Guida per gli sviluppatori dello Streaming gestito da Amazon per Apache Kafka (Amazon MSK)*.
+ Per i dettagli sull'API, consulta [DescribeCluster AWS CLI](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/describe-cluster.html)*Command Reference*.
### `get-bootstrap-brokers`
Il seguente esempio di codice mostra come utilizzare`get-bootstrap-brokers`.
**AWS CLI**
**Come ottenere i broker bootstrap**
L’esempio `get-bootstrap-brokers` seguente recupera le informazioni del broker di bootstrap per un cluster Amazon MSK.
```
aws kafka get-bootstrap-brokers \
--cluster-arn arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5
```
Output:
```
{
"BootstrapBrokerString": "b-1.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:9092,b-2.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:9092",
"BootstrapBrokerStringTls": "b-1.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:9094,b-2.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:9094"
}
```
Per ulteriori informazioni, consulta [Ottenere i broker bootstrap](https://docs.aws.amazon.com/msk/latest/developerguide/msk-get-bootstrap-brokers.html) nella *Guida per gli sviluppatori dello Streaming gestito da Amazon per Apache Kafka (Amazon MSK)*.
+ Per i dettagli sull'API, consulta [GetBootstrapBrokers AWS CLI](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/get-bootstrap-brokers.html)*Command Reference*.
### `list-clusters`
Il seguente esempio di codice mostra come utilizzare`list-clusters`.
**AWS CLI**
**Come elencare i cluster disponibili**
L'`list-clusters`esempio seguente elenca i cluster Amazon MSK nel tuo AWS account.
```
aws kafka list-clusters
```
Output:
```
{
"ClusterInfoList": [
{
"BrokerNodeGroupInfo": {
"BrokerAZDistribution": "DEFAULT",
"ClientSubnets": [
"subnet-cbfff283",
"subnet-6746046b"
],
"InstanceType": "kafka.m5.large",
"SecurityGroups": [
"sg-f839b688"
],
"StorageInfo": {
"EbsStorageInfo": {
"VolumeSize": 100
}
}
},
"ClusterArn": "arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5",
"ClusterName": "demo-cluster-1",
"CreationTime": "2020-07-09T02:31:36.223000+00:00",
"CurrentBrokerSoftwareInfo": {
"KafkaVersion": "2.2.1"
},
"CurrentVersion": "K3AEGXETSR30VB",
"EncryptionInfo": {
"EncryptionAtRest": {
"DataVolumeKMSKeyId": "arn:aws:kms:us-east-1:123456789012:key/a7ca56d5-0768-4b64-a670-339a9fbef81c"
},
"EncryptionInTransit": {
"ClientBroker": "TLS_PLAINTEXT",
"InCluster": true
}
},
"EnhancedMonitoring": "DEFAULT",
"OpenMonitoring": {
"Prometheus": {
"JmxExporter": {
"EnabledInBroker": false
},
"NodeExporter": {
"EnabledInBroker": false
}
}
},
"NumberOfBrokerNodes": 2,
"State": "ACTIVE",
"Tags": {},
"ZookeeperConnectString": "z-2.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:2181,z-1.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:2181,z-3.demo-cluster-1.xuy0sb.c5.kafka.us-east-1.amazonaws.com:2181"
}
]
}
```
Per ulteriori informazioni, consulta [Elencazione dei cluster Amazon MSK](https://docs.aws.amazon.com/msk/latest/developerguide/msk-list-clusters.html) nella *Guida per gli sviluppatori dello Streaming gestito da Amazon per Apache Kafka (Amazon MSK)*.
+ Per i dettagli sull'API, consulta *AWS CLI Command [ListClusters](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/list-clusters.html)Reference*.
### `update-broker-storage`
Il seguente esempio di codice mostra come utilizzare`update-broker-storage`.
**AWS CLI**
**Come aggiornare l’archiviazione EBS per i broker**
L’esempio `update-broker-storage` seguente aggiorna la quantità di archiviazione EBS per tutti i broker del cluster. Amazon MSK imposta la quantità di storage di destinazione per ogni broker sulla quantità specificata nell’esempio. Puoi ottenere la versione corrente del cluster descrivendo il cluster o elencando tutti i cluster.
```
aws kafka update-broker-storage \
--cluster-arn "arn:aws:kafka:us-west-2:123456789012:cluster/MessagingCluster/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2" \
--current-version "K21V3IB1VIZYYH" \
--target-broker-ebs-volume-info "KafkaBrokerNodeId=ALL,VolumeSizeGB=1100"
```
L’output restituisce un ARN per questa operazione `update-broker-storage`. Per determinare se l’operazione è completa, utilizza il comando `describe-cluster-operation` con questo ARN come input.
```
{
"ClusterArn": "arn:aws:kafka:us-west-2:123456789012:cluster/MessagingCluster/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2",
"ClusterOperationArn": "arn:aws:kafka:us-west-2:123456789012:cluster-operation/V123450123/a1b2c3d4-1234-abcd-cdef-22222EXAMPLE-2/a1b2c3d4-abcd-1234-bcde-33333EXAMPLE"
}
```
Per ulteriori informazioni, consulta [Aggiornamento dello storage EBS for broker](https://docs.aws.amazon.com/msk/latest/developerguide/msk-update-storage.html) nella *Guida per gli sviluppatori dello Streaming gestito da Amazon per Apache Kafka (Amazon MSK)*.
+ Per i dettagli sull'API, consulta [UpdateBrokerStorage AWS CLI](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/update-broker-storage.html)*Command Reference*.
### `update-cluster-configuration`
Il seguente esempio di codice mostra come utilizzare`update-cluster-configuration`.
**AWS CLI**
**Come aggiornare la configurazione di un cluster Amazon MSK**
L’esempio `update-cluster-configuration` seguente aggiorna la configurazione del cluster MSK esistente specificato. Utilizza una configurazione MSK personalizzata.
```
aws kafka update-cluster-configuration \
--cluster-arn "arn:aws:kafka:us-west-2:123456789012:cluster/MessagingCluster/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2" \
--configuration-info file://configuration-info.json \
--current-version "K21V3IB1VIZYYH"
```
Contenuto di `configuration-info.json`:
```
{
"Arn": "arn:aws:kafka:us-west-2:123456789012:configuration/CustomConfiguration/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2",
"Revision": 1
}
```
L’output restituisce un ARN per questa operazione `update-cluster-configuration`. Per determinare se l’operazione è completa, utilizza il comando `describe-cluster-operation` con questo ARN come input.
```
{
"ClusterArn": "arn:aws:kafka:us-west-2:123456789012:cluster/MessagingCluster/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2",
"ClusterOperationArn": "arn:aws:kafka:us-west-2:123456789012:cluster-operation/V123450123/a1b2c3d4-1234-abcd-cdef-22222EXAMPLE-2/a1b2c3d4-abcd-1234-bcde-33333EXAMPLE"
}
```
Per ulteriori informazioni, consulta [Aggiornare la configurazione di un cluster Amazon MSK](https://docs.aws.amazon.com/msk/latest/developerguide/msk-update-cluster-cofig.html) nella *Guida per gli sviluppatori dello Streaming gestito da Amazon per Apache Kafka (Amazon MSK)*.
+ Per i dettagli sull'API, consulta [UpdateClusterConfiguration AWS CLI](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/update-cluster-configuration.html)*Command Reference*.