婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av

主頁 > 知識庫 > 在Linux環境下安裝Kafka

在Linux環境下安裝Kafka

熱門標簽:在百度地圖標注車輛 撫順移動400電話申請 烏海智能電話機器人 400電話申請方案 做外呼系統的公司違法嗎 貴陽教育行業電話外呼系統 威海人工外呼系統供應商 藍點外呼系統 寧夏房產智能外呼系統要多少錢

一、環境準備

jdk下載地址鏈接:下載地址

zookeeper下載地址鏈接:下載地址

kafka下載地址鏈接:下載地址

1.1 Java環境為前提

1.1.1 上傳jdk-8u261-linux-x64.rpm到服務器并安裝

# 安裝命令
rpm -ivh jdk-8u261-linux-x64.rpm 

1.1.2 配置環境變量

# 編輯配置文件,jdk的bin目錄到/etc/profile文件,對所有用戶的shell有效
vim /etc/profile
# 生效
source /etc/profile

export JAVA_HOME=/usr/java/jdk1.8.0_261-amd64
export PATH=$PATH:$JAVA_HOME/bin

# 驗證
java -version


至此,jdk安裝成功。

1.2 Zookeeper的安裝配置

1.2.1 上傳zookeeper-3.4.14.tar.gz到服務器,解壓到/opt

# 解壓zk到指定目錄
tar -zxf zookeeper-3.4.14.tar.gz -C /opt


1.2.2 修改Zookeeper保存數據的目錄,dataDir

# 進入conf配置目錄
cd /opt/zookeeper-3.4.14/conf
# 復制zoo_sample.cfg命名為zoo.cfg
cp zoo_sample.cfg zoo.cfg
# 編輯zoo.cfg文件
vim zoo.cfg
dataDir=/var/riemann/zookeeper/data



1.2.3 編輯/etc/profile,使配置生效

設置環境變量ZOO_LOG_DIR,指定Zookeeper保存日志的位置;
ZOOKEEPER_PREFIX指向Zookeeper的解壓目錄;
Zookeeperbin目錄添加到PATH中:

export ZOOKEEPER_PREFIX=/opt/zookeeper-3.4.14
export PATH=$PATH:$ZOOKEEPER_PREFIX/bin
export ZOO_LOG_DIR=/var/riemann/zookeeper/log

配置完以后再生效配置:

source /etc/profile 

1.2.4 啟動Zookeeper,確認Zookeeper的狀態

zkServer.sh start

至此,zookeeper安裝成功。

1.3 Kafka 的安裝與配置

1.3.1 上傳kafka_2.12-1.0.2.tgz到服務器并解壓

tar -zxf kafka_2.12-1.0.2.tgz -C /opt


1.3.2 配置環境變量并生效

vim /etc/profile 
export KAFKA=/opt/kafka_2.12-1.0.2
export PATH=$PATH:$KAFKA/bin
source /etc/profile 

1.3.3 配置/opt/kafka_2.12-1.0.2/config中的server.properties文件

vi  /opt/kafka_2.12-1.0.2/config/server.properties

Kafka連接Zookeeper的地址,此處使用本地啟動的Zookeeper實例
連接地址是localhost:2181
后面的 myKafkaKafka在Zookeeper中的根節點路徑


配置kafka存儲持久化數據目錄

log.dirs=/var/riemann/kafka/kafka-logs

創建上述持久化數據目錄

mkdir -p /var/riemann/kafka/kafka-logs

1.4 啟動Kafka

進入Kafka安裝的根目錄,執行如下命令:

kafka-server-start.sh ../config/server.properties


啟動成功,可以看到控制臺輸出的最后一行的started狀態:此時kafka安裝成功。

1.5 重新開一個窗口,查看Zookeeper的節點


1.6 此時Kafka是前臺模式啟動,要停止,使用Ctrl+C

如果要后臺啟動,使用命令:

kafka-server-start.sh -daemon config/server.properties 

查看Kafka的后臺進程:

ps -ef | grep kafka

停止后臺運行的Kafka:

kafka-server-stop.sh 

二、生產與消費

查看zookeeper狀態,zookeeper啟動成功,再啟動kafka。


2.1 kafka-topics.sh 用于管理主題

查看命令的幫助信息

[root@master1 bin]# kafka-topics.sh
Create, delete, describe, or change a topic.
Option                                   Description                            
------                                   -----------                            
--alter                                  Alter the number of partitions,        
                                           replica assignment, and/or           
                                           configuration for the topic.         
--config <String: name=value>            A topic configuration override for the 
                                           topic being created or altered.The   
                                           following is a list of valid         
                                           configurations:                      
                                         	cleanup.policy                        
                                         	compression.type                      
                                         	delete.retention.ms                   
                                         	file.delete.delay.ms                  
                                         	flush.messages                        
                                         	flush.ms                              
                                         	follower.replication.throttled.       
                                           replicas                             
                                         	index.interval.bytes                  
                                         	leader.replication.throttled.replicas 
                                         	max.message.bytes                     
                                         	message.format.version                
                                         	message.timestamp.difference.max.ms   
                                         	message.timestamp.type                
                                         	min.cleanable.dirty.ratio             
                                         	min.compaction.lag.ms                 
                                         	min.insync.replicas                   
                                         	preallocate                           
                                         	retention.bytes                       
                                         	retention.ms                          
                                         	segment.bytes                         
                                         	segment.index.bytes                   
                                         	segment.jitter.ms                     
                                         	segment.ms                            
                                         	unclean.leader.election.enable        
                                         See the Kafka documentation for full   
                                           details on the topic configs.        
--create                                 Create a new topic.                    
--delete                                 Delete a topic                         
--delete-config <String: name>           A topic configuration override to be   
                                           removed for an existing topic (see   
                                           the list of configurations under the 
                                           --config option).                    
--describe                               List details for the given topics.     
--disable-rack-aware                     Disable rack aware replica assignment  
--force                                  Suppress console prompts               
--help                                   Print usage information.               
--if-exists                              if set when altering or deleting       
                                           topics, the action will only execute 
                                           if the topic exists                  
--if-not-exists                          if set when creating topics, the       
                                           action will only execute if the      
                                           topic does not already exist         
--list                                   List all available topics.             
--partitions <Integer: # of partitions>  The number of partitions for the topic 
                                           being created or altered (WARNING:   
                                           If partitions are increased for a    
                                           topic that has a key, the partition  
                                           logic or ordering of the messages    
                                           will be affected                     
--replica-assignment <String:            A list of manual partition-to-broker   
  broker_id_for_part1_replica1 :           assignments for the topic being      
  broker_id_for_part1_replica2 ,           created or altered.                  
  broker_id_for_part2_replica1 :                                                
  broker_id_for_part2_replica2 , ...>                                           
--replication-factor <Integer:           The replication factor for each        
  replication factor>                      partition in the topic being created.
--topic <String: topic>                  The topic to be create, alter or       
                                           describe. Can also accept a regular  
                                           expression except for --create option
--topics-with-overrides                  if set when describing topics, only    
                                           show topics that have overridden     
                                           configs                              
--unavailable-partitions                 if set when describing topics, only    
                                           show partitions whose leader is not  
                                           available                            
--under-replicated-partitions            if set when describing topics, only    
                                           show under replicated partitions     
--zookeeper <String: urls>               REQUIRED: The connection string for    
                                           the zookeeper connection in the form 
                                           host:port. Multiple URLS can be      
                                           given to allow fail-over.            
[root@master1 bin]# 
# 列出現有的主題
[root@master1 ~]# kafka-topics.sh --list --zookeeper localhost:2181/myKafka
# 創建主題,該主題包含一個分區,該分區為Leader分區,它沒有Follower分區副本。
[root@master1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --create --topic topic_test --partitions 1 --replication-factor 1
# 查看分區信息
[root@master1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --list
# 查看指定主題的詳細信息
[root@master1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --describe --topic topic_test 
# 刪除指定主題
[root@master1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --delete --topic topic_test 

列出現有主題,創建主題,該主題包含一個分區,該分區為Leader分區,它沒有Follower分區副本。

查看指定主題的詳細信息


創建主題,該主題包含多個分區

多個分區:橫向擴展
多個副本:高可用

2.2 kafka-console-consumer.sh用于消費消息

# 開啟消費者
[root@node1 ~]# kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_test 
# 開啟消費者方式二,從頭消費,不按照偏移量消費
[root@node1 ~]# kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_test --from-beginning

2.3 kafka-console-producer.sh用于生產消息

# 開啟生產者
[root@node1 ~]# kafka-console-producer.sh --topic topic_test --broker-list  localhost:9020

2.4 具體操作

開啟消費者和生產者,生產并消費消息。


消費者,按照偏移量消費


消費者從頭消費,不按照偏移量消費

到此這篇關于在Linux環境下安裝Kafka的文章就介紹到這了,更多相關Linux下安裝Kafka內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家!

標簽:蕪湖 周口 泰州 銅川 朝陽 慶陽 那曲 松原

巨人網絡通訊聲明:本文標題《在Linux環境下安裝Kafka》,本文關鍵詞  在,Linux,環境,下,安裝,Kafka,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《在Linux環境下安裝Kafka》相關的同類信息!
  • 本頁收集關于在Linux環境下安裝Kafka的相關信息資訊供網民參考!
  • 推薦文章
    婷婷综合国产,91蜜桃婷婷狠狠久久综合9色 ,九九九九九精品,国产综合av
    亚洲va天堂va国产va久| 午夜精品视频在线观看| 制服丝袜av成人在线看| 另类欧美日韩国产在线| 国产精品久久99| 91精品国产全国免费观看| 国产一区二区按摩在线观看| 亚洲综合激情网| 专区另类欧美日韩| 26uuu精品一区二区在线观看| 欧美亚洲一区二区在线观看| 国产精品一区二区三区99| 一区二区久久久| 午夜在线成人av| 日本不卡视频在线| 日本欧美加勒比视频| 天堂成人免费av电影一区| 亚洲一区二区三区视频在线| 亚洲欧美日韩一区二区三区在线观看| 中文字幕av一区 二区| 国产精品国产三级国产三级人妇| 欧美xxxx老人做受| 久久精品免视看| 日韩三级电影网址| 一本色道久久综合精品竹菊| 午夜久久电影网| 欧美刺激午夜性久久久久久久 | 国产一区二区三区在线观看精品| 91小视频免费观看| 久久久精品黄色| 捆绑调教美女网站视频一区| 欧美国产一区视频在线观看| 欧美午夜精品久久久| 日韩视频免费观看高清完整版在线观看 | 成人高清免费观看| 99久久99久久精品国产片果冻| 国产精品久久久99| 美女mm1313爽爽久久久蜜臀| 国产福利一区二区三区视频在线 | 粉嫩嫩av羞羞动漫久久久 | 久久久电影一区二区三区| 成人avav在线| 欧美美女喷水视频| av不卡一区二区三区| 美腿丝袜在线亚洲一区| 一片黄亚洲嫩模| 日本不卡123| 欧美天堂亚洲电影院在线播放| 男人的天堂亚洲一区| 亚洲永久精品国产| 狠狠色狠狠色综合日日91app| 成人激情免费网站| 91精品国产综合久久久蜜臀粉嫩| 欧美在线观看视频一区二区三区| 欧美体内she精高潮| 中文字幕欧美国产| 免费成人美女在线观看| 欧美性生活久久| 香蕉久久夜色精品国产使用方法 | 99久久伊人精品| 日韩av电影一区| 国产成人在线电影| 日韩美女天天操| 国产资源在线一区| 亚洲人快播电影网| 欧美精品久久久久久久多人混战| 56国语精品自产拍在线观看| 肉丝袜脚交视频一区二区| 欧美一激情一区二区三区| 国产一区二区在线观看免费| 精品国产一区二区三区不卡| www.av亚洲| 日本系列欧美系列| 亚洲精品国产一区二区精华液| 精品国产青草久久久久福利| 色吧成人激情小说| 国产成人综合在线| 日韩精品福利网| 国产精品萝li| 精品动漫一区二区三区在线观看| 成人91在线观看| 国产一区欧美一区| 亚洲国产日日夜夜| 精品国产一区二区精华| 国产精品亚洲第一区在线暖暖韩国| 国产清纯白嫩初高生在线观看91 | 亚洲欧洲国产日韩| 丁香婷婷综合五月| 欧美一级一级性生活免费录像| 欧美电影免费观看高清完整版在线 | 国产九色精品成人porny| 亚洲成人自拍偷拍| 亚洲裸体xxx| 国产精品久久久久婷婷| 久久亚洲精品国产精品紫薇| 精品在线你懂的| 日韩电影在线一区二区| 亚洲18色成人| 亚洲图片欧美色图| 亚洲成a人v欧美综合天堂下载| 欧美一区二区精美| 欧美中文字幕一区| 成人激情av网| 国产成人精品午夜视频免费| 成人午夜电影网站| 国产精品自拍三区| 欧美系列亚洲系列| 久久中文字幕电影| 一区二区三区四区在线播放| 国产精品1024| 欧美四级电影在线观看| 久久久无码精品亚洲日韩按摩| 中文字幕一区在线| 国产精品一区在线观看你懂的| 一本到不卡免费一区二区| 欧美成人精品二区三区99精品| 国产精品私房写真福利视频| 欧美国产一区二区| 日韩激情在线观看| a4yy欧美一区二区三区| 日韩一级片网址| 亚洲成人一区在线| 91久久一区二区| 一区二区三区欧美在线观看| 狠狠色丁香婷婷综合| 欧美精品乱人伦久久久久久| 国产精品三级av| 成人蜜臀av电影| 国产欧美视频一区二区| 喷水一区二区三区| 9191国产精品| 日本亚洲视频在线| 91精品国产入口| 午夜精品久久久久久久久| 在线影院国内精品| 亚洲综合在线视频| 欧美日韩一区二区三区视频| 五月天久久比比资源色| 国产精品三级在线观看| 成人av第一页| 一区二区三区自拍| 欧美丰满美乳xxx高潮www| 午夜电影久久久| 亚洲美女一区二区三区| 色综合久久九月婷婷色综合| 亚洲mv在线观看| 日韩一级欧美一级| 国产69精品久久777的优势| 美女视频黄频大全不卡视频在线播放| 欧美大片日本大片免费观看| 成人性生交大片免费看视频在线| 一区二区免费视频| 久久影音资源网| 国产精品88av| 丰满少妇在线播放bd日韩电影| 亚洲人成网站精品片在线观看| 日韩午夜小视频| 色婷婷av一区| 不卡的看片网站| 国内精品国产成人| 国产日韩综合av| 日韩欧美中文字幕公布| 日韩视频在线永久播放| 日韩中文欧美在线| 亚洲欧洲一区二区三区| 91小视频在线| 欧美亚洲国产一区在线观看网站| 久久国内精品视频| 青青青伊人色综合久久| 亚洲成人免费看| 亚洲18女电影在线观看| 久久久777精品电影网影网| 欧美日韩一二三| 成人激情小说乱人伦| 日韩伦理av电影| 精品在线你懂的| 亚洲色图制服丝袜| 久久亚洲春色中文字幕久久久| 色综合婷婷久久| 精品亚洲国产成人av制服丝袜| 日本欧美一区二区在线观看| 免费在线观看精品| 久久久精品日韩欧美| 国产亚洲欧美色| 久久精品亚洲麻豆av一区二区| 精品国产精品一区二区夜夜嗨| 久久在线观看免费| 91久久精品一区二区二区| 国产精品亚洲视频| 国产美女精品人人做人人爽| 亚洲一区二区三区不卡国产欧美| 亚洲地区一二三色| 七七婷婷婷婷精品国产| 国产成人自拍在线| av影院午夜一区| 日韩精品综合一本久道在线视频| 久久夜色精品一区| 亚洲国产精品影院| 午夜视频在线观看一区二区 | 成熟亚洲日本毛茸茸凸凹|