デモ

この例では、PythonでFPT Kafkaに接続し、producerからメッセージを送信して、consumerでメッセージを読み取る方法を説明します。開始前に、topic・credential・適切なACLを作成しておく必要があります。その他の接続詳細はメニューのDocumentセクションを参照してください。

Part 1：producerがtopicにメッセージを送信する

1. producer.pyファイルを作成します。

   

2. producer.pyに以下の値を設定します：

   

   • sasl_plain_usernameとsasl_plain_password：作成したcredentialのusernameとpassword
   • topic：Write権限が付与された作成済みtopicの名前
   • bootstrap.servers：adminから割り当てられたクラスターアドレス

3. ターミナルを開き、以下を実行します：

   python .\producer.py

   期待される出力：

   

   出力が正しければ、producerはtopicのpartitionにメッセージを正常に送信できています。

Part 2：consumerがメッセージを読み取る

1. consumer.pyファイルを作成します。

   

   

2. consumer.pyに以下の値を設定します：

   

   • group_name：topicへのRead権限が付与されたconsumer groupの名前
   • sasl_plain_usernameとsasl_plain_password：作成したcredentialのusernameとpassword
   • topic：WriteとRead両方の権限が付与されたtopicの名前
   • bootstrap.servers：adminから割り当てられたクラスターアドレス

3. ターミナルを開き、以下を実行します：

   python .\consumer.py

   期待される出力：