Ada lebih banyak contoh AWS SDK yang tersedia di repo Contoh [SDK AWS Doc](https://github.com/awsdocs/aws-doc-sdk-examples). GitHub 

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

# Amazon MSK contoh menggunakan AWS CLI
<a name="cli_2_kafka_code_examples"></a>

Contoh kode berikut menunjukkan cara melakukan tindakan dan menerapkan skenario umum dengan menggunakan MSK AWS Command Line Interface with Amazon.

*Tindakan* merupakan kutipan kode dari program yang lebih besar dan harus dijalankan dalam konteks. Sementara tindakan menunjukkan cara memanggil fungsi layanan individual, Anda dapat melihat tindakan dalam konteks dalam skenario terkait.

Setiap contoh menyertakan tautan ke kode sumber lengkap, di mana Anda dapat menemukan instruksi tentang cara mengatur dan menjalankan kode dalam konteks.

**Topics**
+ [Tindakan](#actions)

## Tindakan
<a name="actions"></a>

### `create-cluster`
<a name="kafka_CreateCluster_cli_2_topic"></a>

Contoh kode berikut menunjukkan cara menggunakan`create-cluster`.

**AWS CLI**  
**Untuk membuat cluster MSK Amazon**  
`create-cluster`Contoh berikut membuat cluster MSK bernama `MessagingCluster` dengan tiga node broker. File JSON bernama `brokernodegroupinfo.json` menentukan tiga subnet di mana Anda ingin Amazon MSK untuk mendistribusikan node broker. Contoh ini tidak menentukan tingkat pemantauan, sehingga cluster mendapatkan `DEFAULT` level.  

```
aws kafka create-cluster \
    --cluster-name "MessagingCluster" \
    --broker-node-group-info file://brokernodegroupinfo.json \
    --kafka-version "2.2.1" \
    --number-of-broker-nodes 3
```
Isi dari `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"
}
```
Untuk informasi selengkapnya, lihat [Membuat Cluster MSK Amazon](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-cluster.html) di *Amazon Managed Streaming for Apache* Kafka.  
+  Untuk detail API, lihat [CreateCluster](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/create-cluster.html)di *Referensi AWS CLI Perintah*. 

### `create-configuration`
<a name="kafka_CreateConfiguration_cli_2_topic"></a>

Contoh kode berikut menunjukkan cara menggunakan`create-configuration`.

**AWS CLI**  
**Untuk membuat konfigurasi MSK Amazon kustom**  
`create-configuration`Contoh berikut membuat konfigurasi MSK kustom dengan properti server yang ditentukan dalam file 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
```
Isi dari `configuration.txt`:  

```
auto.create.topics.enable = true
zookeeper.connection.timeout.ms = 2000
log.roll.ms = 604800000
```
Perintah ini tidak menghasilkan 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"
}
```
Untuk informasi selengkapnya, lihat [Operasi Konfigurasi MSK Amazon di Panduan](https://docs.aws.amazon.com/msk/latest/developerguide/msk-configuration-operations.html) Pengembang *Amazon Managed Streaming for Apache* Kafka.  
+  Untuk detail API, lihat [CreateConfiguration](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/create-configuration.html)di *Referensi AWS CLI Perintah*. 

### `describe-cluster`
<a name="kafka_DescribeCluster_cli_2_topic"></a>

Contoh kode berikut menunjukkan cara menggunakan`describe-cluster`.

**AWS CLI**  
**Untuk menggambarkan sebuah cluster**  
`describe-cluster`Contoh berikut menjelaskan cluster MSK Amazon.  

```
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"
    }
}
```
Untuk informasi selengkapnya, lihat [Mendaftarkan Cluster MSK Amazon di Panduan](https://docs.aws.amazon.com/msk/latest/developerguide/msk-list-clusters.html) Pengembang *Amazon Managed Streaming for Apache* Kafka.  
+  Untuk detail API, lihat [DescribeCluster](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/describe-cluster.html)di *Referensi AWS CLI Perintah*. 

### `get-bootstrap-brokers`
<a name="kafka_GetBootstrapBrokers_cli_2_topic"></a>

Contoh kode berikut menunjukkan cara menggunakan`get-bootstrap-brokers`.

**AWS CLI**  
**Untuk mendapatkan broker bootstrap**  
`get-bootstrap-brokers`Contoh berikut mengambil informasi broker bootstrap untuk cluster MSK Amazon.  

```
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"
}
```
Untuk informasi selengkapnya, lihat [Mendapatkan Broker Bootstrap](https://docs.aws.amazon.com/msk/latest/developerguide/msk-get-bootstrap-brokers.html) di *Amazon Managed Streaming for Apache Kafka* Developer Guide.  
+  Untuk detail API, lihat [GetBootstrapBrokers](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/get-bootstrap-brokers.html)di *Referensi AWS CLI Perintah*. 

### `list-clusters`
<a name="kafka_ListClusters_cli_2_topic"></a>

Contoh kode berikut menunjukkan cara menggunakan`list-clusters`.

**AWS CLI**  
**Untuk daftar cluster yang tersedia**  
`list-clusters`Contoh berikut mencantumkan kluster MSK Amazon di akun Anda AWS .  

```
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"
        }
    ]
}
```
Untuk informasi selengkapnya, lihat [Mendaftarkan Cluster MSK Amazon di Panduan](https://docs.aws.amazon.com/msk/latest/developerguide/msk-list-clusters.html) Pengembang *Amazon Managed Streaming for Apache* Kafka.  
+  Untuk detail API, lihat [ListClusters](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/list-clusters.html)di *Referensi AWS CLI Perintah*. 

### `update-broker-storage`
<a name="kafka_UpdateBrokerStorage_cli_2_topic"></a>

Contoh kode berikut menunjukkan cara menggunakan`update-broker-storage`.

**AWS CLI**  
**Untuk memperbarui penyimpanan EBS untuk broker**  
`update-broker-storage`Contoh berikut memperbarui jumlah penyimpanan EBS untuk semua broker di cluster. Amazon MSK menetapkan jumlah penyimpanan target untuk setiap broker ke jumlah yang ditentukan dalam contoh. Anda bisa mendapatkan versi cluster saat ini dengan menjelaskan cluster atau dengan mencantumkan semua 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"
```
Output mengembalikan ARN untuk operasi ini`update-broker-storage`. Untuk menentukan apakah operasi ini selesai, gunakan `describe-cluster-operation` perintah dengan ARN ini sebagai 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"
}
```
Untuk informasi selengkapnya, lihat [Memperbarui Penyimpanan EBS untuk Broker di Panduan](https://docs.aws.amazon.com/msk/latest/developerguide/msk-update-storage.html) Pengembang *Amazon Managed Streaming for Apache* Kafka.  
+  Untuk detail API, lihat [UpdateBrokerStorage](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/update-broker-storage.html)di *Referensi AWS CLI Perintah*. 

### `update-cluster-configuration`
<a name="kafka_UpdateClusterConfiguration_cli_2_topic"></a>

Contoh kode berikut menunjukkan cara menggunakan`update-cluster-configuration`.

**AWS CLI**  
**Untuk memperbarui konfigurasi kluster MSK Amazon**  
`update-cluster-configuration`Contoh berikut memperbarui konfigurasi cluster MSK yang ada yang ditentukan. Ini menggunakan konfigurasi MSK khusus.  

```
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"
```
Isi dari `configuration-info.json`:  

```
{
    "Arn": "arn:aws:kafka:us-west-2:123456789012:configuration/CustomConfiguration/a1b2c3d4-5678-90ab-cdef-11111EXAMPLE-2",
    "Revision": 1
}
```
Output mengembalikan ARN untuk operasi ini`update-cluster-configuration`. Untuk menentukan apakah operasi ini selesai, gunakan `describe-cluster-operation` perintah dengan ARN ini sebagai 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"
}
```
Untuk informasi selengkapnya, lihat [Memperbarui Konfigurasi Cluster MSK Amazon di Panduan](https://docs.aws.amazon.com/msk/latest/developerguide/msk-update-cluster-cofig.html) Pengembang *Amazon Managed Streaming for Apache* Kafka.  
+  Untuk detail API, lihat [UpdateClusterConfiguration](https://awscli.amazonaws.com/v2/documentation/api/latest/reference/kafka/update-cluster-configuration.html)di *Referensi AWS CLI Perintah*.