安裝和啟動,見官方文檔。
kafka-php weibo的github包是好例子。值得好好研究。里邊n多的回調函數真是磨人。。。
kafka配置,listeners 如果允許集群網服務器訪問,必須配置ip+port,不然只能集群內訪問。--今天最大的坑。
問題如下:內存超限。
[2017-06-15 14:34:45,897] WARN Unexpected error from ; closing connection (org.apache.kafka.common.network.Selector)
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 458965261 larger than 104857600)
at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:91)
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71)
at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:169)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:150)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:355)
at org.apache.kafka.common.network.Selector.poll(Selector.java:303)
at kafka.network.Processor.poll(SocketServer.scala:494)
at kafka.network.Processor.run(SocketServer.scala:432)
at java.lang.Thread.run(Thread.java:745)
------------------------------------------------------
class not found 解決關鍵利器:
打印autoload.php 或者index.php 檢查spl_register_autolad方法的 include 路徑 拼接方法。
大部分問題都在這里。
不是類的php文件,寫滿公共方法那種,直接用到的時候 include
框架中發現一個變量,沒找到初始化的位置,直接引用,此時分析的方法:全局查找這個變量,應該是提前初始化了。作為全局引用。
