日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

AI 助理
備案控制臺
文檔
有獎?wù){(diào)研
輸入文檔關(guān)鍵字查找

通過開源Kafka腳本工具連接Lindorm流引擎

更新時間：
產(chǎn)品詳情
相關(guān)技術(shù)圈
我的收藏

Lindorm流引擎完全兼容開源Kafka API，您可以通過Kafka腳本工具連接Lindorm流引擎，本文介紹如何通過開源Kafka腳本工具連接Lindorm流引擎。

前提條件

  • 已安裝Java環(huán)境，要求安裝JDK 1.7及以上版本。

  • 已將腳本部署實例IP地址添加至Lindorm實例的白名單中，具體操作請參見設(shè)置白名單。

  • 已獲取Lindorm流引擎的Lindorm Stream Kafka地址，具體操作請參見查看連接地址。

    說明

    Lindorm流引擎的Lindorm Stream Kafka地址為專有網(wǎng)絡(luò)地址，需確保應(yīng)用程序部署的環(huán)境和Lindorm實例使用相同的專有網(wǎng)絡(luò)ID。

操作步驟

  1. 下載開源Kafka腳本工具，下載地址。

  2. 解壓Kafka開源腳本工具。

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

  3. 創(chuàng)建topic。

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

  4. 查看全部存在topic。

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

  5. 刪除topic，會刪除數(shù)據(jù)。

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

  6. 讀取數(shù)據(jù)。

    ./bin/kafka-console-consumer.sh --bootstrap-server <Lindorm Stream Kafka地址> --topic <Topic名> --from-beginning --max-messages <讀取數(shù)據(jù)量>

  7. 寫入數(shù)據(jù)。

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

  8. 獲取消費組消費詳情。

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