kafka安装

Posted 2023-05-28 Clover

下载

下载kafka二进制文件

源码不可用于启动，会报错，无法找到kafka.kafka类

配置

server配置文件config/server.properties

# 每一个broker的唯一标识
broker.id=0

# kafka数据目录
# A comma separated list of directories under which to store log files
log.dirs=/usr/local/bin/kafka_2.12-2.8.0/kafka-logs

# zk集群配置
zookeeper.connect=192.168.190.128:2181,192.168.190.129:2181,192.168.190.130:2181

启动

1. 作为后台守护进程

bin/kafka-server-start.sh -daemon config/server.properties

作为守护进程，运行于后台，控制台不输出日志

启动记录，jps命令会显示有kafka进程

其中QuorumPeerMain为zookeeper进程

2. 非守护进程启动

bin/kafka-server-start.sh config/server.properties

非守护进程启动，控制台一直有日志打印，无法输入其它命令、操作

创建topic

#创建topic
bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092
#查看topic
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
#查看topic描述
bin/kafka-topics.sh --describe --bootstrap-server localhost:9092

生产和消费

#控制台生产者
bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
#k
bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092

linux安装kafka

参考技术A

Apache官网 http://kafka.apache.org/downloads.html

tar -xzf kafka_2.10-0.8.2.2.tgz

cd kafka_2.10-0.8.2.2

KAFKA需要启动两个服务：

1，启动zookeeper： bin/zookeeper-server-start.sh config/zookeeper.properties & (&能在执行指令时退出操作)

2，启动kafka： bin/kafka-server-start.sh config/server.properties &

1，创建topic

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

创建一个名为test的topic，只有一个副本，一个分区。

2，创建生产者，启动producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

topic要对应之前创建的topic

之后便可以发送消息

3，创建消费者，启动consumer

bin/kafka-console-consumer.sh --zookeeper 10.202.4.179:2181 --topic test --from-beginning

topic要对应之前创建的topic

在生产者发送消息后，消费者便可以收到对应的消息了

http://blog.csdn.net/suifeng3051/article/details/48053965