Windows で Apache Kafka を実行するにはどうすればいいですか?

[[383471]]

[51CTO.com クイック翻訳] Windows はあなたの好みの開発環境ですか? Windows で Apache Kafka を実行したいですか? Windows Subsystem for Linux 2 (WSL 2) のおかげで、それが可能になりました。 Windows は、本番ワークロードで Kafka を実行するための推奨プラットフォームではありませんが、Kafka を試してみたい場合はまったく問題ありません。これをどうやって行うか見てみましょう。

1. 環境を構築する

WSL 2をインストールする

Windows Subsystem for Linux 2 によりこれが可能になります。 Microsoft によれば、WSL 2 は「従来の仮想マシンやデュアルブート設定のオーバーヘッドがなく、変更されていない、Windows 上に直接存在する GNU/Linux 環境 (ほとんどのコマンドライン ツール、ユーティリティ、アプリケーションを含む)」です。

Windows 10 バージョン 1903.18362 以降を実行していることを確認してください。 [スタート] をクリックし、[設定] > [システム] > [バージョン情報] に移動します。 「Windows の仕様」セクションで「OS バージョン」を見つけます。

図1

Windows Update を使用している場合は、おそらく最新バージョンがインストールされており、すぐに使用できます。そうでない場合は、Windows 10 を更新する必要があります。

Windows が最新であることが確実な場合は、以下の手順に従って WSL 2 をインストールしてください。

Windows Subsystem for Linux を有効にする

Linux ディストリビューションをインストールする前に、Windows Subsystem for Linux 機能を有効にします。管理者として PowerShell を開き、次のコマンドを実行します。

 dism.exe /online /enable-feature /featurename:Microsoft-Windows-Subsystem-Linux / all /norestart

これには1〜2分かかる場合があります。出力は次のようになります。

展開イメージのサービスと管理ツール
バージョン: 10.0.18362.1139
イメージバージョン: 10.0.18363.1139
機能を有効にする
[==========================100.0%===========================]
操作は正常に完了しました。

仮想マシン機能を有効にする

WSL 2 には仮想マシン プラットフォーム機能が必要です。 PowerShell で、次のコマンドを実行します。

 dism.exe /online /enable-feature /featurename:VirtualMachinePlatform / all /norestart

Linuxカーネルのアップデートを入手する

通常の Windows インストーラー (.msi) ファイルである Linux カーネル更新パッケージをダウンロードします。

.msi ファイルをダブルクリックして、WSL 2 の更新プログラムをインストールします。権限の昇格を求めるメッセージが表示された場合は、「はい」を選択してインストールを承認します。

デフォルトのWSLバージョンを設定する

PowerShell で次のコマンドを実行して、WSL 2 を Linux ディストリビューションのデフォルト バージョンとして設定します。

 wsl --set-default-version 2  

出力は次のようになります。

詳細については  WSL 2との主な違いについては、https://aka.ms/wsl2 をご覧ください。

WSL 2 はすぐに使用できます。トラブルシューティングを含む WSL 2 のインストールの詳細については、Windows 10 の Windows Subsystem for Linux インストール ガイドを参照してください。

お気に入りのLinuxディストリビューションをインストールする

Windows に他のアプリケーションをインストールするのと同じように、Microsoft Store から Linux をインストールします。

Microsoft Store アプリを開き、「Linux」を検索します。

図2

この記事ではUbuntu 20.04を使用します。 Ubuntu 20.04 LTSを選択し、「インストール」をクリックします。

インストールが完了したら、「起動」をクリックします。シェルが開き、次のメッセージが表示されます。

インストール中です。数分かかる場合があります...

デフォルトの UNIX ユーザー アカウントを作成してください。ユーザー名は Windows ユーザー名と一致する必要はありません。

詳細については、https://aka.ms/wslusers をご覧ください。

新しい UNIX ユーザー名を入力してください:

インストールを完了するには、ユーザー名とパスワードを入力してください。

図3

Javaをインストールする

最新のアップデートを取得するには、パッケージ マネージャーを実行します。上記で開いた Ubuntu シェル ウィンドウで、次のコマンドを実行します。

 sudo apt-getアップデート&& sudo apt-get アップグレード -y
 ℹ️ ヒント:右クリックすると、テキストがターミナル ウィンドウに貼り付けられます。

Kafka には、Java Runtime Environment バージョン 8 以上が必要です。 Linux インストールの Java バージョンを確認します。

 java バージョン

入力は次のようになります。

 openjdk バージョン"1.8.0_265"  
 OpenJDK ランタイム環境 (ビルド 1.8.0_265-8u265-b01-0ubuntu2~20.04-b01)
 OpenJDK 64ビットサーバー VM (ビルド 25.265-b01、混合モード)

Java がインストールされていないか適切なバージョンでない場合は、ディストリビューションのパッケージ マネージャーを使用してインストールします。 Java をインストールする方法は多数あります。 Ubuntu では、これが最も簡単な方法の 1 つです。

 sudo apt install openjdk-8-jdk -y

Kafkaをダウンロード

パッケージ マネージャーを使用して Kafka をインストールすることも、tarball をダウンロードしてローカル マシンに直接解凍することもできます。

Kafka ダウンロード サイトからイメージを選択し、パッケージ ファイルをダウンロードします。次のコマンドは、Apache Kafka バージョン 2.6 をダウンロードします。

 https://ftp.wayne.edu/apache/kafka/2.6.0/kafka_2.13-2.6.0.tgz を取得します。

次のコマンドを実行して、Kafka の圧縮パッケージを解凍し、cd を使用して kafka ディレクトリに切り替えます。

 tar -xzf kafka_2.13-2.6.0.tgz
 kafka_2.13-2.6.0をインストールします

ls –al コマンドを実行して、kafka ディレクトリの内容を一覧表示します。

合計 64
 drwxr-xr-x 7 jim jim 4096 10月14日 12:27 ./
 drwxr-xr-x 25 jim jim 4096 11月20日 12:52 ../
 -rw-r --r-- 1 jim jim 29975 7月28日 11:16 ライセンス 
 -rw-r --r-- 1 jim jim 337 7月28日 11:16 通知 
 drwxr-xr-x 3 ジム ジム 4096 7 月 28 日 11:23 bin/
 drwxr-xr-x 2 jim jim 4096 7月28日 11:23 config/
 drwxr-xr-x 2 jim jim 4096 10月14日 12:26 libs/
 drwxr-xr-x 2 jim jim 4096 10月14日 12:28 ログ/
 drwxr-xr-x 2 ジム ジム 4096 7月 28 日 11:23 site-docs/

Kafkaクラスターを起動する

ZooKeeper を起動するには、次のコマンドを実行します。

 bin/zookeeper-server-start.sh config/zookeeper.properties

出力は大量にあり、ZooKeeper は通常 1 〜 2 秒ですぐに準備が完了します。

別のターミナルセッションを開きます。ディレクトリを kafka ディレクトリに変更し、Kafka エージェントを起動します。

 kafka_2.13-2.6.0をインストールします 
 bin/kafka-server-start.sh config/server.properties

ウィンドウを並べて配置した場合、出力は次のスクリーンショットのようになります。

図 4. Windows および WSL 2 上で実行されている Ubuntu 20.04 上の ZooKeeper (左) と Kafka ブローカー (右)。

いくつかのメッセージを生成して消費する

別のターミナル セッションを開き、kafka-topics コマンドを実行して、quickstart-events という Kafka トピックを作成します。

 kafka_2.13-2.6.0をインストールします
bin/kafka-topics.sh --create --topic クイックスタートイベント --bootstrap-server ローカルホスト:9092  

出力は次のようになります。

最初のイベント
2番目のイベント
3番目のイベント

プロデューサーとコンシューマーのターミナルウィンドウを並べて配置します。プロデューサー ターミナルで、さらにいくつかのメッセージを入力し、それらがコンシューマー ターミナルにどのように表示されるかを確認します。

図5

カフカを止めろ

Kafka を試した後は、次の手順に従って Kafka 環境を終了します。

1. Ctrl+Cを使用してコンシューマークライアントとプロダクションクライアントを停止します。

2. Ctrl+C で Kafka エージェントを停止します

3. Ctrl+C を押して ZooKeeper サーバーを停止します

4. クリーンアップするには、次のコマンドを実行します。

 rm -rf /tmp/kafka-logs /tmp/zookeeper

原題: Windows で Apache Kafka を実行する方法、著者: Jim Galasyn

[51CTOによる翻訳。パートナーサイトに転載する場合は、元の翻訳者と出典を51CTO.comとして明記してください。