kafka 安装和基本操作

kafka 的版本差异

安装kafka（1.x集群版）

分别在三台机器执行以下步骤：

1. tar -zxvf .
2. 进入到config目录下修改server.properties以下内容
   broker.id=0 //当前broker唯一id
   listeners=PLAINTEXT://192.168.11.140:9092 //kafak之间的通信
   zookeeper.connect //zookeeper集群地址
3. 启动
   sh kafka-server-start.sh -daemon ../config/server.properties //守护进程指定配置文件启动服务
   sh kafka-server-stop.sh //停止服务
   4.日志查看
   tail -100f xxx.log

zookeeper上注册的节点信息

cluster, controller, controller_epoch, brokers, zookeeper, admin, isr_change_notification, consumers, latest_producer_id_block, config
controller – 控制节点
brokers – kafka集群的broker信息 。 topic
consumer – ids/owners/offsets

基本操作

1. Create a topic
   命令：bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
   replication-factor – 副本数
   partitions – 分区数
2. Send some messages
   命令：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
   This is a message
   This is another message
3. Start a consumer
   命令：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning