这篇文章主要为大家展示了“如何安装Kafka”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“如何安装Kafka”这篇文章吧。
创新互联建站是一家专业提供晋宁企业网站建设,专注与成都做网站、成都网站建设、H5高端网站建设、小程序制作等业务。10年已为晋宁众多企业、政府机构等服务。创新互联专业网站制作公司优惠进行中。
首先安装Docker,Docker为Windows、Mac都提供了安装包 Docker Desktop. 安装即可用,这个包涵了多个docker组件,包括 docker compose、docker swarm、docker-machine。
1)、安装Docker Desktop
2)、拉取ubuntu系统,作为实验的操作系统
Docker pull ubuntu
3)、启动ubuntu系统,并进入
Docker run -it --name kafka ubuntu bash 进入
4)、下载kafka安装包
下载Kafka
https://www.apache.org/dyn/closer.cgi?path=/kafka/2.3.0/kafka_2.11-2.3.0.tgz
将kafka拷贝到docker ubuntu 容器中
docker cp kafka_2.11-2.3.0.tgz kafka:/usr/local/kafka
tar -zxvf kafka_2.11-2.3.0.tgz
5)、配置JDK环境
下载JDK1.8 并拷贝到kafka容器中,并配置
6)、启动Kafka自带Zookeeper服务
启动ZK
bin/zookeeper-server-start.sh config/zookeeper.properties
7)、启动Kakfa环境
启动kafka
bin/kafka-server-start.sh config/server.properties
8)、创建topic 指定副本以及分区个数
另外启动控制台,通过docker exec -it kafka bash 进入容器中,创建一个topic z指定副本数为1,分区数为1,topic为test
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
9)、启动生产者Demo
开启kafka生产者进程,输入hello kafka
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
10)、启动消费者Demo
启动kafka消费者进程
以上是“如何安装Kafka”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联行业资讯频道!