在hub.docker.com网站上,Star最多的kafka镜像是wurstmeister/kafka,今天一起来实践这个镜像,使用此镜像搭建kafka环境,并且生产和消费消息;
https://developer.aliyun.com/article/988818
操作系统:CentOS7
Docker:24.0.2
docker-compose:v2.18.1
在docker-compose.yml所在的文件夹下,执行命令,会先下载zookeeper和kafka的镜像,然后创建容器;
执行命令,可见启动了一个zookeeper和三个kafka容器:
执行以下命令查看容器中的kafka版本号:
上述命令执行后,我这边控制台显示kafka_2.11-0.11.0.3,这表示Scala 的版本为2.11,kafka的版本是0.11.0.3;
执行以下命令查看zookeeper版本:
创建一个topic,名为topic001,3个partition,副本因子2,执行以下命令即可:
执行以下命令查看刚刚创建的topic,这次在容器kafka-2上执行命令试试:
可见刚刚创建的topic可以被查到;
查看刚刚创建的topic的情况,borker和副本情况一目了然,如下:
执行如下命令,即可进入等待topic为topic001消息的状态:
目前还没有生产消息,因此控制台不会有内容输出,接下来尝试生产消息;
打开一个新的窗口,执行如下命令,进入生产消息的命令行模式,注意不要漏掉参数"-it"