中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

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

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

在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

溆浦县| 黔西县| 共和县| 赤壁市| 屏东市| 邯郸市| 广德县| 庆安县| 开原市| 集安市| 阜康市| 乡城县| 梁山县| 凤城市| 六盘水市| 来宾市| 庄河市| 宜兰市| 南澳县| 青岛市| 六枝特区| 海伦市| 绥化市| 武山县| 玉环县| 上饶县| 堆龙德庆县| 宁武县| 长沙县| 赤壁市| 齐河县| 上犹县| 隆回县| 洪江市| 额济纳旗| 柳河县| 大名县| 平乡县| 墨脱县| 镇康县| 安远县|