このトピックでは、ApsaraMQ for Kafka が複数のプログラミング言語向けに提供するソフトウェア開発キット (SDK) について説明します。
はじめに
SDKファイルには、デモ、ライブラリファイル、ツールチェーン、およびコンパイルスクリプトが含まれています。Message Queue for Apache Kafka SDKを使用する場合、SDKを開発するためのコードを記述する必要はありません。SDKがインストールされているディレクトリに移動し、SDKのファイルに必要な情報を指定して、SDKをコンパイルできます。
SDK
次の表は、ApsaraMQ for Kafka がさまざまなプログラミング言語向けに提供する SDK について説明しています。表のリンクをたどって、SDK をダウンロードし、SDK の使用方法を学び、SDK の更新履歴を確認できます。
SDK | デモ | サポートされているプロトコル | リファレンス | READMEファイル |
Java SDK |
| |||
Python SDK |
| |||
C++ SDK |
| |||
Go SDK |
| |||
PHP SDK |
| |||
Ruby SDK |
| |||
Node.js SDK |
| |||
C# SDK | なし |
|
使用上の注意
インスタンスエンドポイント
クライアントでエンドポイントを選択します。ApsaraMQ for Kafka は、クライアントを Message Queue for Apache Kafka インスタンスに接続し、メッセージを送受信するための以下のエンドポイントを提供します。
[デフォルトエンドポイント]：デフォルトエンドポイントを使用して ApsaraMQ for Kafka インスタンスに接続し、メッセージを送受信します。
[SSLエンドポイント]：SSLエンドポイントを使用して ApsaraMQ for Kafka インスタンスに接続し、PLAIN認証に基づいてメッセージを送受信します。PLAIN認証は、ユーザー名とパスワードを検証するために使用される単純な認証メカニズムです。ApsaraMQ for Kafka は、インスタンスを再起動することなく、インスタンスの Simple Authentication and Security Layer (SASL) ユーザーを動的に作成できる、最適化された PLAIN 認証を提供します。
重要インスタンスをデプロイし、SSL証明書が 1,024 ビット証明書である場合、セキュリティを強化するために SSL 証明書を 4,096 ビット証明書にアップグレードできます。詳細については、「SSL証明書アルゴリズムを更新する」をご参照ください。
[SASLエンドポイント]：SASLエンドポイントを使用して、仮想プライベートクラウド (VPC) 経由で ApsaraMQ for Kafka インスタンスに接続し、PLAIN認証または SCRAM-SHA-256 認証に基づいてメッセージを送受信します。SASLエンドポイントを使用する場合、次の認証メカニズムを使用できます。
PLAIN：ユーザー名とパスワードを検証するために使用される単純な認証メカニズムです。ApsaraMQ for Kafka は、インスタンスを再起動することなく、インスタンスの SASL ユーザーを動的に作成できる PLAIN 認証を提供します。
SCRAM-SHA-256：クライアントとブローカーでユーザー名とパスワードを検証できるハッシュベースの認証メカニズムです。SCRAM-SHA-256 認証は、PLAIN認証よりも優れたセキュリティを提供します。SCRAM-SHA-256 認証では、ApsaraMQ for Kafka インスタンスを再起動することなく、インスタンスの SASL ユーザーを動的に作成することもできます。
詳細については、「エンドポイント間の比較」をご参照ください。
デモ
使用する SDK のデモファイルを取得し、必要な情報を指定して、プログラムを実行してメッセージを送受信します。詳細については、SDK のデモリンクをクリックし、表示されるページに表示される手順に従ってください。
関連情報
ネットワークタイプに基づいて ApsaraMQ for Kafka インスタンスを購入およびデプロイします。ApsaraMQ for Kafka 詳細については、「VPC接続インスタンスを購入およびデプロイする」および「インターネットおよび VPC 接続インスタンスを購入およびデプロイする」をご参照ください。
メッセージを送受信するために使用するトピックと グループ を作成します。詳細については、「手順 3：リソースを作成する」をご参照ください。
Message Queue for Apache Kafka は、インターネットおよび VPC 接続インスタンスのデフォルトの SASL ユーザーの ID のみを確認し、そのデフォルトの SASL ユーザーにインスタンス内のすべてのトピックとすべてのコンシューマーグループの読み取りと書き込みを許可します。きめ細かいアクセス制御を実行する場合は、アクセス制御リスト (ACL) 機能を有効にし、SASLユーザーを作成し、ビジネス要件に基づいて ApsaraMQ for Kafka インスタンスのリソースに対する特定の権限を SASL ユーザーに付与します。ACL機能を有効にすると、システムは SASL ユーザーに付与されたデフォルトの権限を取り消します。詳細については、「SASLユーザーに権限を付与する」をご参照ください。