# kafka zookeeper 설치
apt install openjdk-11-jre-headless
sudo mkdir /usr/local/kafka-server
cd /usr/local/kafka-server
wget https://downloads.apache.org/kafka/3.2.3/kafka-3.2.3-src.tgz
sudo tar -xzf kafka-3.2.3-src.tgz
sudo mv kafka_2.12-3.0.0/* ./
wget https://downloads.apache.org/kafka/3.2.3/kafka_2.12-3.2.3.tgz
sudo tar -xzf kafka_2.12-3.2.3.tgz
mv kafka_2.12-3.2.3/* ./
#서비스 등록
vi /etc/systemd/system/zookeeper.service
[Unit]
Description=Apache Zookeeper Server
Requires=network.target remote-fs.target
After=network.target remote-fs.target
[Service]
Type=simple
ExecStart=/usr/local/kafka-server/bin/zookeeper-server-start.sh /usr/local/kafka-server/config/zookeeper.properties
ExecStop=/usr/local/kafka-server/bin/zookeeper-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
# 서비스 등록
vi /etc/systemd/system/kafka.service
[Unit]
Description=Apache Kafka Server
Documentation=http://kafka.apache.org/documentation.html
Requires=zookeeper.service
After=zookeeper.service
[Service]
Type=simple
Environment="JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64"
ExecStart=/usr/local/kafka-server/bin/kafka-server-start.sh /usr/local/kafka-server/config/server.properties
ExecStop=/usr/local/kafka-server/bin/kafka-server-stop.sh
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
vi config/server.properties
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://10.10.10.34:9092
# 토픽 생성
./bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
# 토픽 리스트
./bin/kafka-topics.sh --list --bootstrap-server localhost:9092
# 컨슈머 실행
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
# 다른 쉘에서 프로듀서 실행
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
값 입력시, 컨슈머 쪽 쉘에서 수신되는거 확인
#cmak 설치
wget https://github.com/yahoo/CMAK/archive/refs/tags/3.0.0.6.tar.gz
tar -xvzf CMAK-3.0.0.6.tar.gz
cd CMAK-3.0.0.6
./sby clean dist
cd target/universal
unzip cmak-3.0.0.6.zip
mv cmak-3.0.0.6 ~/usr/local/kafka-manager
cd ~/usr/local/kafka-manager
vi conf/application.conf
kafka-manager.zkhosts="localhost:2181"
cmak.zkhosts="localhost:2181"
# 실행
./bin/cmak &
# 서비스등록
vi /etc/systemd/system/kafka-manager.service
[Unit]
Requires=kafka.service
After=kafka.service
[Service]
Type=simple
#User=kafka
ExecStart=/usr/local/kafka-manager/bin/cmak -Dpidfile.path=/usr/local/kafka-manager/RUNNING_PID
ExecStop=/usr/local/kafka-manager/bin/cmak stop
Restart=on-abnormal
[Install]
WantedBy=multi-user.target
# 자바 버전 변경
# 자바8 로 바꿔서 설치..
update-alternatives --config java
'ubuntu 22.04' 카테고리의 다른 글
ubuntu 22.04 es, kibana 설치 (0) | 2023.02.20 |
---|---|
ubuntu 22.04 filebeat 설치 (0) | 2023.02.16 |
ubuntu 22.04 cassandra 설치 (0) | 2023.02.16 |
ubuntu 22.04 fluentd 설치 (0) | 2023.01.16 |
ubuntu 22.04 fluent-bit 설치 (0) | 2023.01.16 |