kafka

简单使用

  1. 创建一个topic
    kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
  2. 创建一个消费者
    kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
  3. 创建一个消息生产者
    kafka-console-producer.sh --broker-list localhost:9092 --topic test

为什么需要中间件

想象一个场景,你的一个创建订单的操作,在订单创建完成之后,需要触发一系列其他的操作,比如进行用户订单数据的统计、给用户发送短信、给用户发送邮件等等

createOrder(...){
 ...
 statOrderData(...);
 sendSMS();
 sendEmail();
}

官方资料

中文手册
配置说明
命令操作
PHP客户端

相关资料

kafka docker-compose
es-docker-compose
kafka入门使用

Kafka简明教程

发表评论