kafka学习

发表于   |   分类于   |     |  

Kafka是一种高吞吐量的分布式发布订阅消息系统。它是一个分布式的、可分区的、可复制的消息系统。应用很广泛。

登录：

ssh登录kafka服务器，进入目录：

/home/lc/kafka_2.9.2-0.8.1

创建topic

bin/kafka-topics.sh –create –topic UploadReadingTime –zookeeper 192.168.1.10:6830 –partitions 8 –replication-factor 1

其中：UploadReadingTime为新创建的主题名
10.211.95.114:6830为zk的地址

创建生产者producer（进入bin目录下）

./kafka-console-producer.sh –broker-list 192.168.2.10:5811 –topic UploadReadingTime

其中：192.168.2.10:5811为kafka地址
UploadReadingTime为主题名

创建消费者consumer（进入bin目录下）

./kafka-console-consumer.sh -zookeeper 192.168.1.10:6830 –topic UploadReadingTime

其中：192.168.1.10:6830为zookeeper地址
UploadReadingTime为主题名

创建完生产者和消费者之后，发送kafka的MQ消息，能够在消费者界面查看到传过来的kafka消息

kafka的配置文件目录

kafka_2.9.2-0.8.1/config/server.properties

ZK服务器：

1
2
3
4
5
6
7
/home/ds/zk/zk/bin>  

./zk

./zkCli.sh -server 192.168.1.10:6830

ls /brokers/topics 　　　　---查看topic

client服务器：

1
2
3
4
5
6
7
8
9
class/

vi openas.cluster.xml

portal/mqconfig/

vi kafka-producer.properties

vi /etc/hosts

查看kafka进程

ps -ef | grep kafka

停止kafka进程

kill -9 进程号