通過開源Kafka指令碼工具串連Lindorm流引擎 -

Lindorm流引擎完全相容開源Kafka API，您可以通過Kafka指令碼工具串連Lindorm流引擎，本文介紹如何通過開源Kafka指令碼工具串連Lindorm流引擎。

前提條件

已安裝Java環境，要求安裝JDK 1.7及以上版本。
已將用戶端IP地址添加至Lindorm白名單。
已擷取Lindorm流引擎的Lindorm Stream Kafka地址。
說明
Lindorm流引擎的Lindorm Stream Kafka地址為專用網路地址，需確保應用程式部署的環境和Lindorm執行個體使用相同的專用網路ID。

解壓Kafka開源指令碼工具。

tar -zxf kafka_2.12-2.7.1.tgz
cd kafka_2.12-2.7.1

建立topic。

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka地址> --topic <Topic名> --partitions <Patition數量> --create

查看全部存在topic。

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka地址> --list

刪除topic，會刪除資料。

./bin/kafka-topics.sh --bootstrap-server <Lindorm Stream Kafka地址> --topic <Topic名> --delete

讀取資料。

./bin/kafka-console-consumer.sh --bootstrap-server <Lindorm Stream Kafka地址> --topic <Topic名> --from-beginning --max-messages <讀取資料量>

寫入資料。

./bin/kafka-console-producer.sh --bootstrap-server <Lindorm Stream Kafka地址> --topic <Topic名>

擷取消費組消費詳情。

./bin/kafka-consumer-groups.sh --bootstrap-server <Lindorm Stream Kafka地址> --group <Group名> --describe