建站
咨詢
售后
建站咨詢
新聞中心
首先下載安裝包,解壓對應的壓縮包,注意efak只需要efak-web-3.0.1這個包即可
wget https://downloads.apache.org/kafka/3.3.1/kafka_2.13-3.3.1.tgz
wget https://github.com/smartloli/kafka-eagle-bin/archive/v3.0.1.tar.gz
提前安裝好jdk8環(huán)境 和mysql
1 kafka-2.13配置
這個版本的kafka不需要額外使用zookeeper了，本身安裝包里面已經(jīng)自帶了，直接啟動即可。
首先修改config目錄下的server.properties
#broker 的全局唯一編號，不能重復，只能是數(shù)字。
broker.id=0
#處理網(wǎng)絡請求的線程數(shù)量
num.network.threads=3
#用來處理磁盤 IO 的線程數(shù)量
num.io.threads=8
#發(fā)送套接字的緩沖區(qū)大小
socket.send.buffer.bytes=102400
#接收套接字的緩沖區(qū)大小
socket.receive.buffer.bytes=102400
#請求套接字的緩沖區(qū)大小
socket.request.max.bytes=104857600
#kafka 運行日志(數(shù)據(jù))存放的路徑，路徑不需要提前創(chuàng)建，kafka 自動幫你創(chuàng)建，可以
#配置多個磁盤路徑，路徑與路徑之間可以用"，"分隔
log.dirs=這里寫你的kafka的日志路徑
#topic 在當前 broker 上的分區(qū)個數(shù)
num.partitions=1
#用來恢復和清理 data 下數(shù)據(jù)的線程數(shù)量
num.recovery.threads.per.data.dir=1
# 每個 topic 創(chuàng)建時的副本數(shù)，默認時 1 個副本
offsets.topic.replication.factor=1
#segment 文件保留的最長時間，超時將被刪除
log.retention.hours=168
#每個 segment 文件的大小，默認大 1G
log.segment.bytes=1073741824
# 檢查過期數(shù)據(jù)的時間，默認 5 分鐘檢查一次是否數(shù)據(jù)過期
log.retention.check.interval.ms=300000
#配置連接 Zookeeper 集群地址
zookeeper.connect=127.0.0.1:2181# 配置監(jiān)聽地址(可選，不配置默認就是9092)
listeners=PLAINTEXT://0.0.0.0:端口
advertised.listeners=PLAINTEXT://這里寫你的域名(如果是內網(wǎng)注意/etc/hosts中配置dns):端口
修改bin/kafka-server-start.sh 找到如下片段?
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G -Djava.rmi.server.hostname=這里寫你的域名"
export JMX_PORT="9999"fi
2 efak 配置
配置conf文件夾下的system-config.properties，要注意efak之前的版本該配置文件有差異
# Kafka使用的Zookeeper集群別名，多個集群用逗號分隔，后續(xù)針對不同集群配置都需要別名作前綴
efak.zk.cluster.alias=cluster1# Kafka配置的Zookeeper集群客戶端訪問地址
cluster1.zk.list=127.0.0.1:2181# efak的Web界面訪問端口
efak.webui.port=8048# EFAK跟Zookeeper的大連接數(shù)
kafka.zk.limit.size=25# 開啟metrics
efak.metrics.charts=true
# 保留時間15天
efak.metrics.retain=15kafka.eagle.sasl.enable=false
kafka.eagle.sasl.protocol=SASL_PLAINTEXT
kafka.eagle.sasl.mechanism=PLAINefak.topic.token=這里配置你的密碼(刪除topic時會使用該密碼)
efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://localhost:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
efak.username=這里配置數(shù)據(jù)庫的用戶名
efak.password=這里配置數(shù)據(jù)庫的密碼 用戶信息默認保存在ke數(shù)據(jù)庫中的ke_user表
3 配置環(huán)境變量
配置/etc/profile
export JAVA_HOME=jdk路徑
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/libexport KAFKA_HOME=kafa路徑
export KE_HOME=efak路徑export PATH=${PATH}:${JAVA_HOME}/bin:$KAFKA_HOME/bin:$KE_HOME/bin
按照以上配置應該就可以了，之前出現(xiàn)efak登錄成功后無法顯示kafka的信息，或者刪除topic后顯示404 等等問題基本都是配置沒有正確，百度很多結果，顯示的解決答案都未聲明kafka 和efak版本，導致浪費了很多時間。 如果有遺漏請各位補充，希望以上能幫助到各位
以下命令適用于kafka-2.13版本
啟動zookeeper
nohup 你的路徑/bin/zookeeper-server-start.sh -daemon? 你的路徑/config/zookeeper.properties
啟動kafka
nohup 你的路徑/bin/kafka-server-start.sh -daemon 你的路徑/config/server.properties
查看topic
./kafka-topics.sh --bootstrap-server 127.0.0.1:9092?--list
刪除topic
你的路徑/bin/kafka-topics.sh --bootstrap-server 127.0.0.1:9092?--delete --topic topic名字?
你是否還在尋找穩(wěn)定的海外服務器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機房具備T級流量清洗系統(tǒng)配攻擊溯源，準確流量調度確保服務器高可用性，企業(yè)級服務器適合批量采購，新人活動首月15元起，快前往官網(wǎng)查看詳情吧
標題名稱：單機版本kafka-2.13版本和EFAK-3.0.1安裝-創(chuàng)新互聯(lián)
分享鏈接：http://www.dlmjj.cn/article/cceppi.html
