改名
This commit is contained in:
@@ -13,17 +13,10 @@ interface ConsumerInterface
|
|||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param int $offset
|
* @param Struct $struct
|
||||||
* @param $part
|
|
||||||
* @param int $crc
|
|
||||||
* @param int $magic
|
|
||||||
* @param int $attr
|
|
||||||
* @param int $timestamp
|
|
||||||
* @param string $key
|
|
||||||
* @param string $value
|
|
||||||
* @return mixed
|
* @return mixed
|
||||||
*/
|
*/
|
||||||
public function onHandler(int $offset, $part, int $crc, int $magic, int $attr, int $timestamp, string $key, string $value);
|
public function onHandler(Struct $struct);
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-10
@@ -43,16 +43,7 @@ class Kafka extends \Snowflake\Process\Process
|
|||||||
}
|
}
|
||||||
$class = Snowflake::createObject($namespace);
|
$class = Snowflake::createObject($namespace);
|
||||||
if ($class instanceof ConsumerInterface) {
|
if ($class instanceof ConsumerInterface) {
|
||||||
$class->onHandler(
|
$class->onHandler(new Struct($topic, $part, $message));
|
||||||
$message['offset'],
|
|
||||||
$part,
|
|
||||||
$message['message']['crc'],
|
|
||||||
$message['message']['magic'],
|
|
||||||
$message['message']['attr'],
|
|
||||||
$message['message']['timestamp'],
|
|
||||||
$message['message']['key'],
|
|
||||||
$message['message']['value']
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
} catch (\Throwable $exception) {
|
} catch (\Throwable $exception) {
|
||||||
$this->application->error($exception->getMessage());
|
$this->application->error($exception->getMessage());
|
||||||
|
|||||||
@@ -0,0 +1,42 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
|
||||||
|
namespace Kafka;
|
||||||
|
|
||||||
|
|
||||||
|
class Struct
|
||||||
|
{
|
||||||
|
|
||||||
|
public $offset;
|
||||||
|
|
||||||
|
public $part;
|
||||||
|
public $topic;
|
||||||
|
|
||||||
|
public $crc;
|
||||||
|
public $magic;
|
||||||
|
public $attr;
|
||||||
|
public $timestamp;
|
||||||
|
public $key;
|
||||||
|
public $value;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Struct constructor.
|
||||||
|
* @param $topic
|
||||||
|
* @param $part
|
||||||
|
* @param $message
|
||||||
|
*/
|
||||||
|
public function __construct($topic, $part, $message)
|
||||||
|
{
|
||||||
|
$this->topic = $topic;
|
||||||
|
$this->offset = $message['offset'];
|
||||||
|
$this->part = $part;
|
||||||
|
$this->crc = $message['message']['crc'];
|
||||||
|
$this->magic = $message['message']['magic'];
|
||||||
|
$this->attr = $message['message']['attr'];
|
||||||
|
$this->timestamp = $message['message']['timestamp'];
|
||||||
|
$this->key = $message['message']['key'];
|
||||||
|
$this->value = $message['message']['value'];
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user