重新提交

Author: ayhome

.DS_Store

@@ -0,0 +1,12 @@
+{
+    "name": "ayhome/kafka",
+    "description": "kafka-php-lite",
+    "type": "library",
+    "authors": [
+        {
+            "name": "ayhome",
+            "email": "ayhome@foxmail.com"
+        }
+    ],
+    "require": {}
+}

Exception/Base.php

@@ -1,17 +1,5 @@
 <?php
-// Copyright 2016 The See-KafKa Authors. All rights reserved.
-//
-// Licensed under the Apache License, Version 2.0 (the "License"): you may
-// not use this file except in compliance with the License. You may obtain
-// a copy of the License at
-//
-//     http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-// License for the specific language governing permissions and limitations
-// under the License.
+namespace ayhome\KafKa;
 
 // 通过offset和group来获取消息(必须设置group)
 const KAFKA_OFFSET_STORED = RD_KAFKA_OFFSET_STORED;
@@ -25,7 +13,7 @@
  * KafKa-Consumer类
  * @author : @喵了个咪<wenzhenxi@vip.qq.com>
  */
-class KafKa_Consumer {
+class Consumer {
 
     protected $topic = null;
 

Exception/err.php

@@ -1,31 +1,10 @@
 <?php
-// Copyright 2016 The See-KafKa Authors. All rights reserved.
-//
-// Licensed under the Apache License, Version 2.0 (the "License"): you may
-// not use this file except in compliance with the License. You may obtain
-// a copy of the License at
-//
-//     http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-// License for the specific language governing permissions and limitations
-// under the License.
-
-/**
- * KafKa拓展类
- * @author : @喵了个咪<wenzhenxi@vip.qq.com>
- * 依赖PHP-C拓展:https://github.com/arnaud-lb/php-rdkafka
- * 依赖服务底层:https://github.com/edenhill/librdkafka
- * setKafkaConf和setTopicConf配置说明地址:
- * https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md
- */
+namespace ayhome\KafKa;
 
 // KafKa分区自动随机分配
 const KAFKA_PARTITION_UA = RD_KAFKA_PARTITION_UA;
 
-class KafKa_Lite {
+class KafKa {
 
     // KafKaHostList
     protected $BrokerList = array();

KafKa.php

@@ -0,0 +1,41 @@
+<?php
+namespace ayhome\KafKa;
+class Message
+{
+    /**
+     * @var int
+     */
+    public $err;
+
+    /**
+     * @var string
+     */
+    public $topic_name;
+
+    /**
+     * @var int
+     */
+    public $partition;
+
+    /**
+     * @var string
+     */
+    public $payload;
+
+    /**
+     * @var string
+     */
+    public $key;
+
+    /**
+     * @var int
+     */
+    public $offset;
+
+    /**
+     * @return string
+     */
+    public function errstr()
+    {
+    }
+}