摘要:快速開始快速開始快速開始集群訪問集群訪問申請集群后,系統為每個節點自動分配一個內網。以下快速開始測試來自官方。創建查看發送消息接收消息刪除此命令會標記為刪除狀態,只有當設置為時才會真正刪除數據,默認為。
申請集群后,系統為每個 UKafka 節點自動分配一個內網 IP。kafka 服務監聽 9092 端口,zookeeper 服務監聽 2181 端口。
以下快速開始測試來自 Apache Kafka 官方Quickstart 。
2. 下載 Apache Kafka 代碼登陸可以 ping 通您 UKafka 集群節點的服務器。
下載 Apache Kafka 項目代碼。本文選擇的是 kafka_2.11-2.1.0.tgz。
解壓文件夾:
$ tar -xzvf kafka_2.11-2.1.0.tgz
進入文件夾:$ cd kafka_2.11-2.1.0/bin
3. 基本操作請在實際測試中,將以下 [broker1 IP] 替換成您 UKafka 集群中 Broker ID 為 1 的 IP。
創建Topic$ kafka-topics.sh --zookeeper [broker1 IP]:2181 --create --topic test_ucloud --partitions 3 --replication-factor 3
Created topic "test_ucloud".
查看Topic$ kafka-topics.sh --zookeeper [broker1 IP]:2181 --describe --topic test_ucloud
Topic:test_ucloud PartitionCout:3 ReplicationFactor:3 Configs:
Topic: test_ucloud Partition: 0 Leader: 5 Replicas: 5,1,2 Isr: 5,1,2
Topic: test_ucloud Partition: 1 Leader: 1 Replicas: 1,2,3 Isr: 1,2,3
Topic: test_ucloud Partition: 2 Leader: 2 Replicas: 2,3,4 Isr: 2,3,4
發送消息$ kafka-console-producer.sh --broker-list [broker1 IP]:9092 --topic test_ucloud
[2016-08-11 13:42:31,788] WARN Property topic is not valid(kafka.utils.VerifiableProperties)
hello ukafka
hello ukafka
接收消息$ kafka-console-consumer.sh --bootstrap-server [broker1 IP]:9092 --topic test_ucloud --from-beginning
hello ukafka
hello ukafka
^CConsumed 2 messages
刪除Topic$ kafka-topics.sh --zookeeper [broker1 ip]:2181 --delete --topic test_ucloud
Topic test_ucloud is marked for deletion
Note: This will have no impact if delete.topic.enable is not set to true.
此命令會標記Topic為刪除狀態,只有當delete.topic.enable設置為true時才會真正刪除數據,默認為true。
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/126945.html
摘要:快速開始本例以數據同步到來做說明。創建連接器點擊創建連接器按鈕,打開配置頁面。若下游為,則需配置路徑,若為,則需填寫信息。連接器列表詳情頁數據驗證參考,為集群創建,并寫入消息到其中。快速開始本例以UKafka數據同步到UHadoop來做說明。創建連接器點擊【創建連接器】按鈕,打開配置頁面。配置連接器基本信息配置按需填寫。【上游】意為Kafka連接器上游的Kafka集群,【下游】意為Kafka...
摘要:概覽概覽產品簡介操作指南集群管理節點管理磁盤管理管理管理監控視圖監控項說明開發指南快速開始認證配置與外網訪問客戶端性能測試連接器產品介紹快速開始產品功能性能測試產品價格產品價格 概覽產品簡介操作指南集群管理節點管理磁盤管理Topic管理ConsumerGroup管理監控視圖監控項說明開發指南快速開始認證配置與外網訪問客戶端SDK性能測試FAQsKafka連接器產品介紹快速開始產品功能性能測試...
摘要:大量的和分區會嚴重影響集群性能。介紹可參考收到離線分區總數異常告警一般是某個節點宕機或者服務異常導致。若服務卡住,可在評估后在控制臺重啟該節點服務。若想了解當前請求延時情況,建議關注平均請求延時監控項。 FAQs本篇目錄一個UKafka集群可以創建多少個Topic?如何增加Topic的副本數量(ReplicationFactor)?收到離線分區總數>=10.0個告警,離線分區總數是什么,怎么...
摘要:集群管理集群管理集群管理本篇目錄創建集群創建集群調整集群參數調整集群參數創建集群創建集群創建集群點擊控制臺左上角全部產品選擇消息隊列也可鎖定到左側菜單欄。選擇完畢后,進入集群設置頁面,可對集群參數進行配置。 集群管理本篇目錄創建集群調整集群參數創建集群1. 點擊控制臺左上角全部產品選擇Kafka消息隊列 UKafka,也可鎖定到左側菜單欄。2. 進入UKafka操作界面,點擊創建集群進行UK...
摘要:性能測試性能測試性能測試上游,下游是的連接器節點數分區數數消息大小機型速度消息數核核核核核核核上游,下游是連接器節點數分區數數消息大小機型版本機型節點數分片數副本數速度消息數核核核核核核核核核 性能測試上游UKafka,下游是UHadoop的HDFS 連接器節點數分區數broker數消息大小/byteskafka機型hadoopmasterhadoopcore速度(消息數/s)1331024...
摘要:性能測試性能測試性能測試在不同機型集群默認配置下,利用腳本進行性能基準測試測試結果下載 性能測試在不同機型 ukafka 集群默認配置下,利用 kafka-producer-perf-test.sh 腳本進行性能基準測試測試結果下載
閱讀 421·2024-11-07 18:25
閱讀 130614·2024-02-01 10:43
閱讀 919·2024-01-31 14:58
閱讀 884·2024-01-31 14:54
閱讀 82895·2024-01-29 17:11
閱讀 3188·2024-01-25 14:55
閱讀 2031·2023-06-02 13:36
閱讀 3116·2023-05-23 10:26