Kafka

常用命令

启动 kafka
cd $KAFKA_HOME
bin/kafka-server-start config/server.properties &
停止
bin/kafka-server-stop.sh
创建topic
bin/kafka-topic.sh --create --zookeeper hadoop102:2181 --replication-factor 2 --partitions 3 --topic test
生产消息
bin/kafka-console-producer.sh --broker-list hadoop102:9092 --topic test
消费消息
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic test --from-beginning

kafka拦截器，序列化器，分区器的先后顺序

先调用拦截器，再调用序列化器，最后调用分区器。

Kafka Controller的作用

Kafka Controller 是整个Kafka集群的管理者，依赖ZooKeeper完成整个集群的管理工作。Kafka所有涉及到的元素，比如topic，partition，还有每个broker都会在 ZooKeeper 上创建对应的节点。Kafka Controller 会有多种监控的Listener，哪种节点发生变化就会触发哪个Listener采取相应措施。