当前位置: 首页 > 工具软件 > Apache Druid > 使用案例 >

apache druid安装

欧阳嘉年
2023-12-01

Apache druid运行需要依赖其他一些软件环境,所以需要先安装依赖环境,最后再安装druid。

这些依赖的环境包括:

  • jdk
  • zookeeper
  • kafka

1.1 jdk安装

将jdk包下载下来进去下面操作,如果有可以用最下面的命令查看一下版本
# 解压命令
tar -zxf jdk-8u191-linux-x64.tar.gz -C /usr/local/
# 修改配置命令
vi /etc/profile
# 添加内容:
export JAVA_HOME=/usr/local/jdk1.8.0_191
export PATH=$JAVA_HOME/bin:$PATH
# 配置生效命令
source /etc/profile
#查看java版本命令
java -version

1.2zookeeper安装

#启动容器:
docker run -id --name my_zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime zookeeper:3.4.14
#查看容器运行情况:
docker logs -f my_zookeeper

1.3kafka安装

  • 下载安装

#拉取镜像
docker pull wurstmeister/kafka
#启动容器  这里面需要修改成你现在端口号 (红色部分)
docker run -id --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.17.21:2181 -e  KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.17.21:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -v /etc/localtime:/etc/localtime wurstmeister/kafka
#查看容器运行情况:
docker logs -f kafka
  • 参数说明
     
-e KAFKA_BROKER_ID=0  在kafka集群中,每个kafka都有一个BROKER_ID来区分自己
-e KAFKA_ZOOKEEPER_CONNECT=68.79.63.42:2181 配置zookeeper管理kafka的路径
-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://68.79.63.42:9092  把kafka的地址端口注册给zookeeper
-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口
-v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间
  • 验证

#进入kafka容器 (可以一次性输入进去)
docker exec -it kafka /bin/bash
#进入bin目录  (这里请一步一步cd进去,然后在ls查看一下,可能 kafka_2.12-2.5.0 这个有一些人的是版本不同因为下载的镜像版本不一样,然后最后再进去bin目录)
cd /opt/kafka_2.12-2.5.0/bin/
#执行命令,创建名称为test的队列,此队列有一个副本,一个分区(红色部分改为自己的端口号)
./kafka-topics.sh --create --zookeeper 192.168.17.21:2181 --replication-factor 1 --partitions 1 --topic test
#查看刚刚创建的队列
./kafka-topics.sh -list -zookeeper 192.168.17.21:2181
  • 消息发送和接收 

 接下来通过kafka提供的脚本测试发送消息和接收消息

#执行命令,启动消费端,监听test队列 (启动后后会有光标占用这个不用管)
./kafka-console-consumer.sh --bootstrap-server 192.168.17.21:9092 --topic test --from-beginning
#新开一个命令窗口,启动生产者,向test队列发送消息 (重新开一个端口然后也进入容器里面,同上的操作只需要进入即可,也是需要一步一步进去)
./kafka-console-producer.sh --broker-list 192.168.17.21:9092 --topic test

然后在新的界面输入值,在那个老界面会实现一个监听器的效果,监听你输入的值

#测试完成后按Ctrl+C退出
 类似资料: