Apache Kafka エコシステム用 Azure Event Hubs への移行
Azure Event Hubs は Apache Kafka エンドポイントを公開します。これにより、Kafka プロトコルを使用して Event Hubs に接続できます。 既存の Kafka アプリケーションに最小限の変更を行うことで、Azure Event Hubs に接続し、Azure エコシステムの利点を享受することができます。 Event Hubs は、MirrorMaker を含む既存の Kafka アプリケーションの多くで動作します。 詳細については、Apache Kafka 用の Event Hubs に関するページを参照してください
移行前
Azure アカウントの作成
Azure サブスクリプションをお持ちでない場合は、開始する前に 無料アカウント を作成してください。
Event Hubs 名前空間を作成します
Event Hubs 名前空間とイベント ハブを作成するには、イベント ハブの作成に関する記事の手順に従ってください。
接続文字列
ポータルから接続文字列を取得する方法に関する記事の手順に従います。 また、後で使用するために接続文字列を書き留めておきます。
完全修飾ドメイン名 (FQDN)
また、Event Hubs 名前空間を参照する FQDN が必要になる場合もあります。 FQDN は、次のように接続文字列内で確認できます。
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Event Hubs 名前空間がパブリック クラウド以外にデプロイされている場合は、ドメイン名が異なる場合があります (例: *.servicebus.chinacloudapi.cn、*.servicebus.usgovcloudapi.net、または *.servicebus.cloudapi.de)。
移行
Kafka クライアント構成を更新する
Kafka 対応 Event Hubs に接続するには、Kafka クライアントの構成を更新する必要があります。 見つからない場合は、アプリケーションで bootstrap.servers が設定されている場所を検索してみてください。
アプリケーション内の任意の場所に、次の構成を挿入します。
bootstrap.servers と sasl.jaas.config の値を更新して、正しい認証を使用してクライアントを Event Hubs Kafka エンドポイントに転送するようにしてください。
bootstrap.servers={MYNAMESPACE}.servicebus.windows.net:9093
request.timeout.ms=60000
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{CONNECTION STRING TO YOUR NAMESPACE}";
sasl.jaas.config がフレームワークでサポートされる構成ではない場合、SASL のユーザー名とパスワードを設定に使用される構成を見つけ、代わりにそれらを使用します。 ユーザー名を $ConnectionString に、パスワードを Event Hubs の接続文字列に設定します。
移行後
イベント ハブにイベントを送信する Kafka アプリケーションを実行します。 次に、Azure portal を使用してイベント ハブがイベントを受信することを確認します。 Event Hubs 名前空間の [概要] ページで、 [メトリック] セクションの [メッセージ] ビューに切り替えます。 ページを最新の情報に更新して、グラフを更新します。 メッセージが受信されたことが示されるまでに数秒かかることがあります。
次のステップ
Event Hubs と Kafka 用 Event Hubs の詳細については、次の記事を参照してください。