as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-10-09 17:10:45 +08:00
parent d5fc9d2462
commit 2e8005fda9
1 changed files with 22 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Kafka.php
+22 -21
View File
@@ -35,27 +35,28 @@ class Kafka extends \Snowflake\Process\Process
$consumer = new \Kafka\Consumer(); $consumer = new \Kafka\Consumer();
$consumer->setLogger(new Logger()); $consumer->setLogger(new Logger());
$consumer->start(function ($topic, $part, $message) { $consumer->start(function ($topic, $part, $message) {
var_dump($topic, $part, $message); try {
// $namespace = 'App\Kafka\\' . ucfirst($topic) . 'Consumer'; $namespace = 'App\\Kafka\\' . ucfirst($topic) . 'Consumer';
// if (!class_exists($namespace) || !($namespace instanceof ConsumerInterface)) { if (!class_exists($namespace)) {
// return; return;
// } }
// try { if ($namespace instanceof ConsumerInterface) {
// /** @var ConsumerInterface $class */ /** @var ConsumerInterface $class */
// $class = Snowflake::createObject($namespace); $class = Snowflake::createObject($namespace);
// $class->onHandler( $class->onHandler(
// $message['offset'], $message['offset'],
// $part, $part,
// $message['message']['crc'], $message['message']['crc'],
// $message['message']['magic'], $message['message']['magic'],
// $message['message']['attr'], $message['message']['attr'],
// $message['message']['timestamp'], $message['message']['timestamp'],
// $message['message']['key'], $message['message']['key'],
// $message['message']['value'] $message['message']['value']
// ); );
// } catch (\Throwable $exception) { }
// $this->application->error($exception->getMessage()); } catch (\Throwable $exception) {
// } $this->application->error($exception->getMessage());
}
}); });
} }