建站公司兴田德润简介,携程网网站做的怎么样,做英文网站的心得,wordpress自适应模版目录 2.1 安装部署1、【单机部署】2、【集群部署】 2.2 Kafka命令行操作1、查看topic相关命令参数2、查看当前kafka服务器中的所有Topic3、创建 first topic4、查看 first 主题的详情5、修改分区数#xff08;注意#xff1a;分区数只能增加#xff0c;不能减少#xff09;… 目录 2.1 安装部署1、【单机部署】2、【集群部署】 2.2 Kafka命令行操作1、查看topic相关命令参数2、查看当前kafka服务器中的所有Topic3、创建 first topic4、查看 first 主题的详情5、修改分区数注意分区数只能增加不能减少6、删除 topic7、生产者发送消息8、消费者消费消息 2.1 安装部署
1、【单机部署】
1、下载并上传到nginx服务器 官网http://kafka.apache.org/downloads.html
2、解压安装包
tar -zxvf kafka_2.12-3.0.0.tgz -C /opt/module/3、修改解压后的文件名称 mv kafka_2.12-3.0.0/ kafka4、进入到/mysoft/kafka/config 目录修改配置文件
vim server.properties本地做的修改主要是 broker.id1 delete.topic.enabletrue log.dirs/soft/kafka/logs zookeeper.connect192.168.239.11:2181/kafka 配置文件各个配置意义
5、启动单节点 先启动zookeeper 节点 启动kafka
./kafka-server-start.sh -daemon ../config/server.properties6、查看kafka有没有正常启动 jps
7、配置kafka的环境变量 1在/etc/profile.d/my_env.sh 文件中增加 kafka 环境变量配置
sudo vim /etc/profile.d/my_env.sh增加如下内容
#KAFKA_HOME
export KAFKA_HOME/mysoft/kafka
export PATH$PATH:$KAFKA_HOME/bin2刷新一下环境变量。 source /etc/profile2、【集群部署】
2.2 Kafka命令行操作
1、查看topic相关命令参数
bin/kafka-topics.sh2、查看当前kafka服务器中的所有Topic
bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --list3、创建 first topic
bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --create --partitions 1 --replication-factor 1 --topic first4、查看 first 主题的详情
bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --describe --topic first5、修改分区数注意分区数只能增加不能减少
bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --alter --topic first --partitions 36、删除 topic bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --delete --topic first7、生产者发送消息
bin/kafka-console-producer.sh --bootstrap-server 192.168.239.11:9092 --topic first8、消费者消费消息
消费 first 主题中的数据
bin/kafka-console-consumer.sh --bootstrap-server 192.168.239.11:9092 --topic first把主题中所有的数据都读取出来包括历史数据。
bin/kafka-console-consumer.sh --bootstrap-server 192.168.239.11:9092 --topic first --from-beginning
