成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲 中文字幕 日韩 无码

資訊專欄INFORMATION COLUMN

快速開始 Kafka消息隊(duì)列 UKafka

ernest.wang / 1573人閱讀

摘要：快速開始快速開始快速開始集群訪問集群訪問申請(qǐng)集群后，系統(tǒng)為每個(gè)節(jié)點(diǎn)自動(dòng)分配一個(gè)內(nèi)網(wǎng)。以下快速開始測試來自官方。創(chuàng)建查看發(fā)送消息接收消息刪除此命令會(huì)標(biāo)記為刪除狀態(tài)，只有當(dāng)設(shè)置為時(shí)才會(huì)真正刪除數(shù)據(jù)，默認(rèn)為。

快速開始

1. 集群訪問

申請(qǐng)集群后，系統(tǒng)為每個(gè) UKafka 節(jié)點(diǎn)自動(dòng)分配一個(gè)內(nèi)網(wǎng) IP。kafka 服務(wù)監(jiān)聽 9092 端口，zookeeper 服務(wù)監(jiān)聽 2181 端口。

以下快速開始測試來自 Apache Kafka 官方Quickstart 。

2. 下載 Apache Kafka 代碼

登陸可以 ping 通您 UKafka 集群節(jié)點(diǎn)的服務(wù)器。

下載 Apache Kafka 項(xiàng)目代碼。本文選擇的是 kafka_2.11-2.1.0.tgz。

解壓文件夾：

$ tar -xzvf kafka_2.11-2.1.0.tgz
進(jìn)入文件夾：
$ cd kafka_2.11-2.1.0/bin
3. 基本操作

請(qǐng)?jiān)趯?shí)際測試中，將以下 [broker1 IP] 替換成您 UKafka 集群中 Broker ID 為 1 的 IP。

創(chuàng)建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
發(fā)送消息
$ 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.

此命令會(huì)標(biāo)記Topic為刪除狀態(tài)，只有當(dāng)delete.topic.enable設(shè)置為true時(shí)才會(huì)真正刪除數(shù)據(jù)，默認(rèn)為true。

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://m.hztianpu.com/yun/126945.html

相關(guān)文章

  • Kafka消息隊(duì)列 UKafka

    摘要：快速開始本例以數(shù)據(jù)同步到來做說明。創(chuàng)建連接器點(diǎn)擊創(chuàng)建連接器按鈕，打開配置頁面。若下游為，則需配置路徑，若為，則需填寫信息。連接器列表詳情頁數(shù)據(jù)驗(yàn)證參考，為集群創(chuàng)建，并寫入消息到其中。快速開始本例以UKafka數(shù)據(jù)同步到UHadoop來做說明。創(chuàng)建連接器點(diǎn)擊【創(chuàng)建連接器】按鈕，打開配置頁面。配置連接器基本信息配置按需填寫?！旧嫌巍恳鉃镵afka連接器上游的Kafka集群，【下游】意為Kafka...

    ernest.wang 評(píng)論0 收藏1595

  • 概覽 Kafka消息隊(duì)列 UKafka

    摘要：概覽概覽產(chǎn)品簡介操作指南集群管理節(jié)點(diǎn)管理磁盤管理管理管理監(jiān)控視圖監(jiān)控項(xiàng)說明開發(fā)指南快速開始認(rèn)證配置與外網(wǎng)訪問客戶端性能測試連接器產(chǎn)品介紹快速開始產(chǎn)品功能性能測試產(chǎn)品價(jià)格產(chǎn)品價(jià)格 概覽產(chǎn)品簡介操作指南集群管理節(jié)點(diǎn)管理磁盤管理Topic管理ConsumerGroup管理監(jiān)控視圖監(jiān)控項(xiàng)說明開發(fā)指南快速開始認(rèn)證配置與外網(wǎng)訪問客戶端SDK性能測試FAQsKafka連接器產(chǎn)品介紹快速開始產(chǎn)品功能性能測試...

    ernest.wang 評(píng)論0 收藏2613

  • FAQs Kafka消息隊(duì)列 UKafka

    摘要：大量的和分區(qū)會(huì)嚴(yán)重影響集群性能。介紹可參考收到離線分區(qū)總數(shù)異常告警一般是某個(gè)節(jié)點(diǎn)宕機(jī)或者服務(wù)異常導(dǎo)致。若服務(wù)卡住，可在評(píng)估后在控制臺(tái)重啟該節(jié)點(diǎn)服務(wù)。若想了解當(dāng)前請(qǐng)求延時(shí)情況，建議關(guān)注平均請(qǐng)求延時(shí)監(jiān)控項(xiàng)。 FAQs本篇目錄一個(gè)UKafka集群可以創(chuàng)建多少個(gè)Topic？如何增加Topic的副本數(shù)量(ReplicationFactor)？收到離線分區(qū)總數(shù)>=10.0個(gè)告警，離線分區(qū)總數(shù)是什么，怎么...

    ernest.wang 評(píng)論0 收藏2407

  • 集群管理 Kafka消息隊(duì)列 UKafka

    摘要：集群管理集群管理集群管理本篇目錄創(chuàng)建集群創(chuàng)建集群調(diào)整集群參數(shù)調(diào)整集群參數(shù)創(chuàng)建集群創(chuàng)建集群創(chuàng)建集群點(diǎn)擊控制臺(tái)左上角全部產(chǎn)品選擇消息隊(duì)列也可鎖定到左側(cè)菜單欄。選擇完畢后，進(jìn)入集群設(shè)置頁面，可對(duì)集群參數(shù)進(jìn)行配置。 集群管理本篇目錄創(chuàng)建集群調(diào)整集群參數(shù)創(chuàng)建集群1. 點(diǎn)擊控制臺(tái)左上角全部產(chǎn)品選擇Kafka消息隊(duì)列 UKafka,也可鎖定到左側(cè)菜單欄。2. 進(jìn)入U(xiǎn)Kafka操作界面，點(diǎn)擊創(chuàng)建集群進(jìn)行UK...

    ernest.wang 評(píng)論0 收藏276

  • 性能測試 Kafka消息隊(duì)列 UKafka

    摘要：性能測試性能測試性能測試上游，下游是的連接器節(jié)點(diǎn)數(shù)分區(qū)數(shù)數(shù)消息大小機(jī)型速度消息數(shù)核核核核核核核上游，下游是連接器節(jié)點(diǎn)數(shù)分區(qū)數(shù)數(shù)消息大小機(jī)型版本機(jī)型節(jié)點(diǎn)數(shù)分片數(shù)副本數(shù)速度消息數(shù)核核核核核核核核核 性能測試上游UKafka，下游是UHadoop的HDFS 連接器節(jié)點(diǎn)數(shù)分區(qū)數(shù)broker數(shù)消息大小/byteskafka機(jī)型hadoopmasterhadoopcore速度(消息數(shù)/s)1331024...

    ernest.wang 評(píng)論0 收藏1358

  • 性能測試 Kafka消息隊(duì)列 UKafka

    摘要：性能測試性能測試性能測試在不同機(jī)型集群默認(rèn)配置下，利用腳本進(jìn)行性能基準(zhǔn)測試測試結(jié)果下載 性能測試在不同機(jī)型 ukafka 集群默認(rèn)配置下，利用 kafka-producer-perf-test.sh 腳本進(jìn)行性能基準(zhǔn)測試測試結(jié)果下載

    ernest.wang 評(píng)論0 收藏1086

發(fā)表評(píng)論

0條評(píng)論

閱讀需要支付1元查看
<