LindormストリーミングエンジンのAPIは、オープンソースのApache KafkaのAPIと完全な互換性があります。オープンソースのApache Kafkaスクリプトツールを使用して、Lindormストリーミングエンジンに接続できます。このトピックでは、オープンソースのApache Kafkaスクリプトツールを使用してLindormストリーミングエンジンに接続する方法について説明します。
前提条件
Java Development Kit（JDK） V1.7以降がインストールされている。
クライアントのIPアドレスがApsaraDB for Lindorm（Lindorm）インスタンスのホワイトリストに追加されている。詳細については、ホワイトリストを構成するをご参照ください。
Lindorm Stream Kafkaエンドポイントの値が取得されている。詳細については、エンドポイントの表示をご参照ください。
説明Lindorm Stream Kafkaエンドポイントは、Lindormストリーミングエンジンの仮想プライベートクラウド（VPC）エンドポイントを指定します。アプリケーションとLindormインスタンスが同じVPCにデプロイされていることを確認してください。
手順
こちらをクリックして、オープンソースのApache Kafkaスクリプトツールをダウンロードします。
ダウンロードしたオープンソースのApache Kafkaスクリプトツールを解凍します。
tar -zxf kafka_2.12-2.7.1.tgz cd kafka_2.12-2.7.1トピックを作成します。
./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name> --partitions <Number of Partitions> --create既存のすべてのトピックを表示します。
./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --listトピックを削除します。トピックを削除すると、トピック内のデータも削除されます。
./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name> --deleteトピックからデータを読み取ります。
./bin/kafka-console-consumer.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name> --from-beginning --max-messages <Number of Messages to Read>トピックにデータを書き込みます。
./bin/kafka-console-producer.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --topic <Topic Name>コンシューマーグループの消費ステータスをクエリします。
./bin/kafka-consumer-groups.sh --bootstrap-server <Lindorm Stream Kafka Endpoint> --group <Group Name> --describe