Message Queue for Apache Kafka は、メッセージの送受信を支援するために、複数のプログラミング言語に対応した SDK を提供します。
はじめに
SDK (ソフトウェア開発キット) には、サンプル、ライブラリ、ツールチェーン、およびビルドスクリプトが含まれています。追加の設定を行うことなく、SDK 環境でアプリケーションを直接開発およびコンパイルできます。
SDK
Message Queue for Apache Kafka は、以下のプログラミング言語に対応した SDK を提供します。これらのリンクを使用して、更新履歴の確認、インストールパッケージのダウンロード、およびリファレンスドキュメントにアクセスできます。
| SDK | デモ | 対応プロトコル | リファレンス | README ファイル |
| Java SDK | Java SDK デモ |
|
インスタンスエンドポイントを使用したメッセージの送受信 | README.md |
| Python SDK | Python SDK デモ |
|
Python SDK を使用したメッセージの送受信 | |
| C++ SDK | C++ SDK デモ |
|
C++ SDK を使用したメッセージの送受信 | |
| Go SDK | Go SDK デモ |
|
Go SDK を使用したメッセージの送受信 | README.md |
| PHP SDK | PHP SDK デモ |
|
PHP SDK を使用したメッセージの送受信 | |
| Ruby SDK | Ruby SDK デモ |
|
Ruby SDK を使用したメッセージの送受信 | README.md |
| Node.js SDK | Node.js SDK デモ |
|
Node.js SDK を使用したメッセージの送受信 | README.md |
| C# SDK | N/A |
|
C# SDK を使用したメッセージの送受信 | README.md |
注意事項
インスタンスエンドポイント
クライアントは、異なるエンドポイントを介して Message Queue for Apache Kafka に接続し、メッセージを送受信します。
- [デフォルトのアクセスポイント]：クライアントを Message Queue for Apache Kafka インスタンスに接続し、メッセージを送受信できます。
- [SSL アクセスポイント]：SSL 経由で Message Queue for Apache Kafka インスタンスに接続し、認証に PLAIN メカニズムを使用できます。PLAIN は、ユーザー名とパスワードによる認証方式です。Message Queue for Apache Kafka は PLAIN メカニズムを最適化し、インスタンスを再起動することなく SASL ユーザーを動的に追加できます。重要 インスタンスが 1024 ビットの SSL 証明書を使用していて、より強固なセキュリティが必要な場合は、4096 ビットの証明書にアップグレードできます。詳細については、「SSL 証明書アルゴリズムのアップグレード」をご参照ください。
- [SASL アクセスポイント]：VPC 内で、SASL エンドポイントを使用して Message Queue for Apache Kafka に接続し、PLAIN または SCRAM メカニズムを使用してメッセージを送受信できます。SASL は、以下の認証メカニズムをサポートしています。
- PLAIN：ユーザー名とパスワードによる認証方式です。Message Queue for Apache Kafka の PLAIN メカニズムでは、インスタンスを再起動することなく SASL ユーザーを動的に追加できます。
- Message Queue for Apache KafkaSCRAM-SHA-256：クライアントとサーバーの両方でハッシュアルゴリズムを使用して認証情報を検証する、安全な認証メカニズムです。このメカニズムは PLAIN よりも高いセキュリティを提供し、インスタンスを再起動することなく SASL ユーザーを動的に追加することもできます。
エンドポイントの詳細については、「エンドポイントの比較」をご参照ください。
デモの使用方法
インスタンスに対応するデモを選択し、デモファイルを設定して実行することで、メッセージを送受信できます。詳細な手順については、各言語のドキュメントをご参照ください。
関連ドキュメント
- 必要なネットワークタイプに基づいて Message Queue for Apache KafkaMessage Queue for Apache Kafka インスタンスをデプロイしてください。詳細については、「VPC 経由での Message Queue for Apache Kafka インスタンスへの接続」および「インターネットと VPC からアクセス可能なインスタンスのデプロイ」をご参照ください。
- 必要な コンシューマーグループとトピックを作成してください。詳細については、「ステップ 3：リソースの作成」をご参照ください。
- インターネットまたは VPC インスタンスのデフォルト SASL ユーザーは、ID 検証のみを行います。すべてのトピックとコンシューマーグループに対する読み取りおよび書き込みアクセス許可があります。よりきめ細かなアクセス制御を行うには、ACL 機能を有効にして SASL ユーザーを作成し、特定のアクセス許可を付与してください。ACL 機能を有効にすると、デフォルト SASL ユーザーのアクセス許可は取り消されます。詳細については、「SASL ユーザーへのアクセス許可の付与」をご参照ください。