REST Proxy を Confluent Cloud に接続する¶

Confluent Cloud の Kafka クラスターにある Apache Kafka® トピックに対して生成や消費を行うようにローカルの Confluent REST Proxy を構成できます。

参考

Confluent REST Proxy を使用して Kafka クラスターでデータの生成および消費を行う実践的な例については、Confluent REST Proxy のチュートリアルを参照してください。

REST Proxy を Confluent Cloud に接続するには、Confluent Platform tarball をダウンロードしてから、カスタマイズしたプロパティファイルを使用して REST Proxy を起動する必要があります。

前提条件

Confluent Cloud へのアクセス。
Confluent CLI。

Confluent Platform をダウンロードして、コンテンツを抽出します。
Confluent Cloud CLI を使用して、rest-proxy-test という名前のトピックを作成します。
```
confluent kafka topic create --partitions 4 rest-proxy-test
```

プロパティファイルを作成します。

Cloud Console インターフェイスから CLI & client configuration をクリックして、クラスターのクライアント設定を見つけます。
Clients タブをクリックします。
Java クライアントの選択項目をクリックします。この例では Java クライアントを使用します。

Java クライアントの構成プロパティ¶
Confluent Platform のファイルの場所に、ccloud-kafka-rest.properties という名前のプロパティファイルを作成します。
```
cd <path-to-confluent>
```
```
touch ccloud-kafka-rest.properties
```

Java クライアントの構成プロパティをコピーしてそのファイルに貼り付けます。各セキュリティプロパティに client. プレフィックスを追加します。以下に例を示します。

# Kafka
bootstrap.servers=<myproject>.cloud:9092
security.protocol=SASL_SSL
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule \
required username="<kafka-cluster-api-key>" password="<kafka-cluster-api-secret>";
ssl.endpoint.identification.algorithm=https
sasl.mechanism=PLAIN
client.bootstrap.servers=<myproject>.cloud:9092
client.security.protocol=SASL_SSL
client.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule \
required username="<kafka-cluster-api-key>" password="<kafka-cluster-api-secret>";
client.ssl.endpoint.identification.algorithm=https
client.sasl.mechanism=PLAIN
# Confluent Cloud Schema Registry
schema.registry.url=<schema-registry-URL>
basic.auth.credentials.source=USER_INFO
schema.registry.basic.auth.user.info=<schema-registry-api-key>:<schema-registry-api-secret>

プロデューサー、コンシューマー、管理クライアントは、client. プロパティを共有します。以下のテーブルを参照して、プロデューサー、コンシューマー、または管理クライアントのその他のプロパティを指定します。

コンポーネント	プレフィックス	例
管理クライアント	`admin.`	admin.request.timeout.ms
コンシューマー	`consumer.`	consumer.request.timeout.ms
プロデューサー	`producer.`	producer.acks

これらのプロパティを追加した例を以下に示します。

# Kafka
bootstrap.servers=<myproject>.cloud:9092
security.protocol=SASL_SSL
client.security.protocol=SASL_SSL
client.sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<kafka-cluster-api-key>" password="<kafka-cluster-api-secret>";
client.ssl.endpoint.identification.algorithm=https
sasl.mechanism=PLAIN
client.sasl.mechanism=PLAIN
# Confluent Cloud Schema Registry
schema.registry.url=<schema-registry-URL>
basic.auth.credentials.source=USER_INFO
schema.registry.basic.auth.user.info=<schema-registry-api-key>:<schema-registry-api-secret>

# consumer only properties must be prefixed with consumer.
consumer.retry.backoff.ms=600
consumer.request.timeout.ms=25000

# producer only properties must be prefixed with producer.
producer.acks=1

# admin client only properties must be prefixed with admin.
admin.request.timeout.ms=50000

Confluent Cloud API キーと API シークレットを作成して REST API と通信する方法の詳細については、「Kafka クラスターリソースにアクセスするための認証情報を作成する」を参照してください。

REST Proxy を起動します。

./bin/kafka-rest-start ccloud-kafka-rest.properties

REST API v2 を使用して REST 呼び出しを実行します。

リクエストの例:
```
GET /topics/test HTTP/1.1
Accept: application/vnd.kafka.v2+json
```
注意

API v1 は使用しないでください。API v1 は、Confluent Cloud では機能しない ZooKeeper に依存しています。