3个问题
- 安装 :
a. 看kafka官方文档会知道，kafka主要给java用的，其他的语言多是通过c/c++的api来间接调用的，所以很显然要做的事情就是安装PHP的扩展（使用c的api），另外也有封装好的PHP包（使用PHP的api）
b. 自己撸
https://github.com/edenhill/librdkafka
https://github.com/arnaud-lb/php-rdkafka - 使用
使用方面其实无外乎一进一出，能进能出就算体验了一把。
其实Github上已经给了例子了，我这里copy一下，重点是现在很多网上的文章在入的时候呢，总是采用了循环，反复入，看着挺好，自己真用起来，发现就想入一下的时候问题就来了。这个放到注意事项里面说，先看正确姿势：
<?php
### 创建producer
$conf = new RdKafka\Conf();
$conf->set('log_level', (string) LOG_DEBUG);
$conf->set('debug', 'all');
$rk = new RdKafka\Producer($conf);
$rk->addBrokers("10.0.0.1:9092,10.0.0.2:9092");
### 创建topic
$topic = $rk->newTopic("test");
### 创建message
$topic->produce(RD_KAFKA_PARTITION_UA, 0, "Message payload");
### ！！！你发不成功的！！！
- 注意事项
其实但凡你把别人的用例往下看下，你就会发现别人已经温馨提示了： 小心消息丢失
先说结果，加上后面两句，你就可以发成功了
$producer->poll(0);
$result = $producer->flush(10000);
-
为什么？
可能你根本不会看到这里来，当然也不排除会跟我遇到一样困惑的人：我这里简单说 3 句话：
a. 发消息是异步的
b. 网上其他的demo中（死）循环有一定的迷惑性，你很有可能没注意他每次循环的sleep，或者你会误解这个sleep到底是干什么的，其实就是变相保证消息能发送完；但是你在实际业务当中不一定会是循环发消息，所以很有可能你去掉循环的时候把sleep也去掉了，然后就懵了。
c. 这个flush后面10000(ms)，并不会让你等那么久 -
总结
撸官网！撸官网！撸官网！
不知道有多少人抱着有东西就搜博客来解决，这个没问题，在开搞之前，调研的时候，随便搜搜、随便看看，了解一下是个什么东西没问题，真正动手的时候，看官网的东西绝对是捷径，从最终来看绝对是捷径！就算感觉看不懂英文，没事儿，我也不安慰你，因为你活该，who cares，但是你要撸他的示例代码。就这，over。
网友评论