kafka环境搭建

1、下载kafka安装包

http://kafka.apache.org/downloads

2、解压

tar -zxvf kafka_2.12-2.5.0.tgz -C /home/share/kafka
cd /home/share/kafka/kafka_2.12-2.5.0

 3、开启kafka服务

启动zookeeper
    bin/zookeeper-server-start.sh config/zookeeper.properties

启动Kafka服务端
    bin/kafka-server-start.sh config/server.properties

4、创建topic

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看创建的主题
bin/kafka-topics.sh --list --zookeeper localhost:2181

5、发送消息

producer生产数据   
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
>

consumer来接收数据
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

 

相关文章

# 前言 现有主流消息中间件都是生产者-消费者模型,主要角色...
错误的根源是:kafka版本过高所致,2.2+=的版本,已经不需要...
DWS层主要是存放大宽表数据,此业务中主要是针对Kafka topic...
不多BB讲原理,只教你怎么用,看了全网没有比我更详细的了,...
终于写完了,其实最开始学kafka的时候是今年2月份,那时候还...
使用GPKafka实现Kafka数据导入Greenplum数据库踩坑问题记录(...