91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

在Windows下Kafka的基本配置及簡單使用

發布時間:2020-03-07 16:52:03 來源:網絡 閱讀:3731 作者:簡單的WLY 欄目:軟件技術

首先下載zookeeper(版本zookeeper-3.4.13)和kafka(版本kafka_2.12-2.0.0),解壓就可以使用了。

1、zookeeper:
在config目錄下,有zoo.conf這個配置文件,可以配置端口和日志存儲的位置,可以根據自己習慣更改。
首先啟動zookeeper,如果環境變量中配置過了zookeeper,則可以直接打開cmd窗口,用zkserver來啟動,如下:
在Windows下Kafka的基本配置及簡單使用
如果打印的日志都是INFO 或者WARN,并且進入守護線程狀態,表示啟動成功。

2、Kafka:
在config目錄下,有個server.properties配置文件,有配置日志目錄的: log.dirs=D:/nomalAPP/kafka_2.12-2.0.0/kafka-logs , 還有配置連接的zookeeper的地址的: zookeeper.connect=localhost:2181 。其他的基本不用管,也可以根據具體需要進行修改。
啟動命令為: .\bin\windows\kafka-server-start.bat .\config\server.properties 。如下:
在Windows下Kafka的基本配置及簡單使用
下面還會打印出一些基本配置信息。啟動成功也會進入守護線程狀態。

上面啟動的兩個不要關閉,再繼續進行下面的操作:

3、topic:創建主題
命令為: .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test_topic ,如下所示:
在Windows下Kafka的基本配置及簡單使用
查看已經存在的主題,命令為: .\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181, 如下:
在Windows下Kafka的基本配置及簡單使用

3、producer:生產者
創建生產者的命令:.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test_topic,如下:
在Windows下Kafka的基本配置及簡單使用

4、consumer:消費者
創建消費者的命令: .\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test_topic
但是我在用這個命令時出現了下面的情況:
在Windows下Kafka的基本配置及簡單使用
這是因為使用的kafka版本比較新,上面的這種方式已經過時被刪除了,所以沒法啟動。
這是可以換用另一種: .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic test_topic --from-beginning ,啟動如下:
在Windows下Kafka的基本配置及簡單使用
亂碼問題可以在具體生產者消費者代碼中進行處理。

以上只是一些入門級的基礎操作,進階的搭建集群,集成其他的技術這些,還有待學習!

個人理解:kafka就像是一個過渡管道,用來中轉消息的(消息代理),可能像一個微信公眾號,生產者就是公眾號的管理者,把文章放到公眾號里面,而消費者就像是訂閱這個公眾號的人,只要訂閱了這個公眾號,在有新消息推送到公眾號時,公眾號會把新文章推給訂閱者。
kafka的好處就在于:
(1)可靠性 - Kafka是分布式,它有分區,復制和容錯的。
(2)可擴展性 - Kafka消息傳遞系統輕松縮放,無需停機。
(3)耐用性 - Kafka使用分布式提交日志,這意味著消息會盡可能快地保留在磁盤上,因此它是持久的。
(4)性能 - Kafka對于發布和訂閱消息都具有高吞吐量。 即使存儲了許多TB的消息,它也保持穩定的性能。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

麻栗坡县| 股票| 根河市| 汝南县| 西平县| 昆山市| 玛多县| 绩溪县| 山丹县| 如东县| 通城县| 天峻县| 康保县| 新乡县| 蒙山县| 永寿县| 陈巴尔虎旗| 黔江区| 海口市| 红原县| 墨玉县| 潞西市| 府谷县| 思南县| 信阳市| 闽清县| 红桥区| 斗六市| 云南省| 岳普湖县| 平塘县| 夏邑县| 通榆县| 龙胜| 县级市| 淳安县| 巫山县| 西藏| 射阳县| 德钦县| 沙雅县|