FPGA測試(驗證)之——modelsim自動模擬(帶rom初始化檔案hex)
阿新 • • 發佈:2022-05-20
kafka叢集搭建
1、環境準備
IP | HostName | 應用 | 安裝路徑 |
---|---|---|---|
192.168.0.81 | node81 | zookeeper、kafka | /opt |
192.168.0.82 | node82 | zookeeper、kafka | /opt |
192.168.0.83 | node83 | zookeeper、kafka | /opt |
軟體包下載
軟體 | 版本 | 安裝節點 | 目錄 | 下載地址 |
---|---|---|---|---|
jdk | jdk-17_linux-x64_bin.rpm | node81,node82,node83 | /usr/java/ | https://www.oracle.com/java/technologies/downloads/ |
zookeeper | apache-zookeeper-3.5.6-bin.tar.gz | node81,node82,node83 | /opt/zookeeper | https://archive.apache.org/dist/zookeeper/zookeeper-3.5.6/ |
kafka | kafka_2.13-3.1.0.tgz | node81,node82,node83 | /opt/kafka | https://kafka.apache.org/downloads |
eagle | kafka-eagle-bin-2.1.0.tar.gz | node81 | /opt/kafka-eagle | http://download.kafka-eagle.org/ |
建立普通使用者
useradd hzyyg
passwd hzyyg
2、安裝
2.1、安裝jdk
上傳安裝包到/usr/local/src
目錄下
cd /usr/local/src
rpm -ivh jdk-17_linux-x64_bin.rpm
新增java環境變數
#vim /etc/profile
export JAVA_HOME=/usr/java/jdk-17.0.2
export CLASSPATH=.:${JAVA_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH
#source /etc/profile
測試java
#java -version java version "17.0.2" 2022-01-18 LTS Java(TM) SE Runtime Environment (build 17.0.2+8-LTS-86) Java HotSpot(TM) 64-Bit Server VM (build 17.0.2+8-LTS-86, mixed mode, sharing)
2.2 安裝zookeeper
修改記憶體配置
#vim /etc/security/limits.conf
hzyyg soft nproc 16384
hzyyg hard nproc 16384
hzyyg soft nofile 65535
hzyyg hard nofile 65536
解壓
cd /usr/local/src
mkdir /opt/zookeeper
tar -zxvf apache-zookeeper-3.5.6-bin.tar.gz -C /opt/zookeeper/
建立軟連線,後期方便更新版本
ln -s /opt/zookeeper/apache-zookeeper-3.5.6-bin /opt/zookeeper/zookeeper
新增環境變數
echo -e 'export ZOOKEEPER_HOME=/opt/zookeeper/zookeeper\nexport PATH=$ZOOKEEPER_HOME/bin/$PATH' >> /etc/profile
配置zk配置檔案
cp /opt/zookeeper/zookeeper/conf/zoo_sample.cfg /opt/zookeeper/zookeeper/conf/zoo.cfg
echo 'server.1=192.168.0.81:2888:3888
server.2=192.168.0.82:2888:3888
server.3=192.168.0.83:2888:3888' >> /opt/zookeeper/zookeeper/conf/zoo_sample.cfg
mkdir /opt/zookeeper/data
分別設定myid,node82和83分別設定為2 ,3
#node81
echo 1 > /opt/zookeeper/data/myid
啟動zookeeper
/opt/zookeeper/zookeeper/bin/zkServer.sh start
3、安裝kafka
解壓
cd /usr/local/src
mkdir /opt/kafka
tar -zxvf kafka_2.13-3.1.0.tgz
tar -xzvf kafka-eagle-bin-2.1.0/efak-web-2.1.0-bin.tar.gz -C /opt/kafka-eagle/
建立軟連線
ln -s /opt/kafka/kafka_2.13-3.1.0 /opt/kafka/kafka
環境變數
echo -e 'KAFKA_HOME=/opt/kafka/apache-kafka \nexport PATH=$KAFKA_HOME/bin:$PATH' >> /etc/profile
修改server.conf
broker.id=1
listeners=PLAINTEXT://192.168.0.81:9092
log.dirs=/opt/kafka/kafka-logs
zookeeper.connect=192.168.0.81:2181,192.168.0.82:2181,192.168.0.83:2181
broker.id=2
listeners=PLAINTEXT://192.168.0.82:9092
log.dirs=/opt/kafka/kafka-logs
zookeeper.connect=192.168.0.81:2181,192.168.0.82:2181,192.168.0.83:2181
broker.id=3
listeners=PLAINTEXT://192.168.0.83:9092
log.dirs=/opt/kafka/kafka-logs
zookeeper.connect=192.168.0.81:2181,192.168.0.82:2181,192.168.0.83:2181
啟動kafka
su hzyyg
sudo bin/kafka-server-start.sh -daemon config/server.properties
kafka測試
建立topic
bin/kafka-topics.sh --create --bootstrap-server 192.168.0.81:9092 --replication-factor 1 --partitions 1 --topic test1
bin/kafka-topics.sh --list --bootstrap-server 192.168.0.81:9092
傳送訊息/生產訊息
bin/kafka-console-producer.sh --broker-list 192.168.0.81:9092 --topic test
>hello world
消費訊息
bin/kafka-console-consumer.sh --bootstrap-server 192.168.0.81:9092 --topic test --from-beginning
hello world
4、安裝kafka-eagle
cd /usr/local/src
mkdir /opt/kafka-eagle
tar -zxvf kafka-eagle-bin-2.1.0.tar.gz -C /opt/kafka-eagle/
建立軟連線
ln -s /opt/kafka-eagle/efak-web-2.1.0 /opt/kafka-eagle/efak-web
新增環境變數
echo 'export KE_HOME=/opt/kafka-eagle/kafka-eagle' >> /etc/profile
修改配置檔案
#vim /opt/kafka-eagle/efak-web/conf/system-config.properties
efak.zk.cluster.alias=cluster1
cluster1.zk.list=192.168.0.81:2181,192.168.0.82:2181,192.168.0.83:2181
######################################
# kafka mysql jdbc driver address
######################################
efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://192.168.31.247:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
efak.username=root
efak.password=123456
修改kafka JMX配置
sed -i '/export KAFKA_HEAP_OPTS/a\ export JMX_PORT="7788"' /opt/kafka/kafka/bin/kafka-server-start.sh
cat /opt/kafka/kafka/bin/kafka-server-start.sh | grep -C 2 'export KAFKA_HEAP_OPTS'
啟動kafka-eagle
/opt/kafka-eagle/efak-web/bin/ke.sh start
使用者名稱密碼:admin / 123456