Linux中Kafka的安装配置及简单操作
kafka安装包可以通过官网下载:
Apache Kafka
将压缩包上传到/opt/目录下
解压缩文件
tar -zxvf kafka_2.11-1.0.0.tgz
配置
kafka的配置文件在 config/server.proterties中要修改的参数如下
启动Zookeeper
cd /opt/kafka/bin/zookeeper-server-start.sh -daemon ../config/zookeeper.properties
启动kafka
cd /opt/kafka_2.11-1.0.0/bin ./kafka-server-start.sh -daemon ../config/server.properties
查看是否启动
jps
查看所有主题
cd /opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --list --zookeeper 192.168.222.130:2181
创建主题
cd /opt/kafka/bin/kafka-topic.sh --create --zookeeper ip地址:2181 --partitions 1 --replication-factor 1 --topic 主题
删除主题
cd /opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --delete --zookeeper 192.168.224.130:2181 --topic test
启动生产者-发送消息
cd /opt/kafka/bin/kafka-console-producer.sh --broker-list ip地址:9092 --topic 主题
启动消费者-拉取消息
实时通讯
cd /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server ip地址:9092 --topic 主题
之前的内容也显示
cd /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server ip地址:9092 --topic 主题 --from-beginning
作者:是小裴啊
来源链接:https://blog.csdn.net/peizhengguang/article/details/121400659