Linux中Kafka的安装配置及简单 *** 作

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