高铁建设官方网站,北海涠洲岛旅游网站建设分析,互联网公司职位,网站建设功能描述书1、kafka环境单点
根据官网版本说明(3.6.0)发布#xff0c;zookeeper依旧在使用状态#xff0c;预期在4.0.0大版本的时候彻底抛弃zookeeper使用KRaft(Apache Kafka)官方并给出了zk迁移KR的文档
2、使用docker启动单点kafka 1、首先将kafka启动命令#xff0c;存储为.servi…1、kafka环境单点
根据官网版本说明(3.6.0)发布zookeeper依旧在使用状态预期在4.0.0大版本的时候彻底抛弃zookeeper使用KRaft(Apache Kafka)官方并给出了zk迁移KR的文档
2、使用docker启动单点kafka 1、首先将kafka启动命令存储为.service结尾的系统服务文件并指定存储在/etc/systemd/system/目录下 2、kafk.service文件
[Unit]
Descriptionkafka
Afterdocker.service
Requiresdocker.service
[Service]
TimeoutStartSec0
ExecStartPre-/usr/bin/docker rm kafka
ExecStart/usr/bin/docker run \--name kafka \-v /etc/localtime:/etc/localtime:ro \--log-drivernone \-e HOSTNAMEkafka \-p 9092:9092 \-e KAFKA_BROKER_ID1 \-e KAFKA_CFG_LISTENERSPLAINTEXT://:9092 \-e KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://127.0.0.1:9092 \-e KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper:2181 \-e ALLOW_PLAINTEXT_LISTENERyes \wurstmeister/kafka #kafka版本哦
ExecStop/usr/bin/docker kill kafka
Restartalways
RestartSec5
[Install]
WantedBymulti-user.target 3、使用linux系统命令进行启动 systemctl start kafka.service systemctl logs kafka systemctl status kafka
systemctl status kafka报错/etc/systemd/system/kafka.service:14: Missing . 2、zookeeper
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
使用idea连接zookeeper 1、下载zookeeper插件 2、添加IP和端口 3、flink docker run -itd --namejobmanager --publish 8081:8081 --network flink-network --env FLINK_PROPERTIESjobmanager.rpc.address: jobmanager flink:1.13.5-scala_2.12 jobmanager
docker run -itd --nametaskmanager --network flink-network --env FLINK_PROPERTIESjobmanager.rpc.address: jobmanager flink:1.13.5-scala_2.12 taskmanager
外部访问xxx.xxx.xxx.xxx:8081
