改名

Kafka/Kafka.php

@@ -112,7 +112,6 @@ class Kafka extends \Snowflake\Process\Process
 	protected function handlerExecute($topic, $part, $message)
 	{
 		try {
-			var_dump($message);
 			$namespace = 'App\\Kafka\\' . ucfirst($topic) . 'Consumer';
 			if (!class_exists($namespace)) {
 				return;

Kafka/Struct.php

@@ -4,21 +4,18 @@
 namespace Kafka;
 
 
+use RdKafka\Message;
+
 class Struct
 {
 
-	public $offset;
+	public int $offset;
 
-	public $part;
+	public Message $message;
-	public $topic;
+	public string $topic;
-
-	public $crc;
-	public $magic;
-	public $attr;
-	public $timestamp;
-	public $key;
-	public $value;
 
+	public string $value;
+	public string $part;
 
 	/**
 	 * Struct constructor.
@@ -26,17 +23,13 @@ class Struct
 	 * @param $part
 	 * @param $message
 	 */
-	public function __construct($topic, $part, $message)
+	public function __construct($topic, $part,Message $message)
 	{
 		$this->topic = $topic;
-		$this->offset = $message['offset'];
+		$this->offset = $message->offset;
-		$this->part = $part;
+		$this->part = $message->partition;
-		$this->crc = $message['message']['crc'];
+		$this->message = $message;
-		$this->magic = $message['message']['magic'];
+		$this->value = $message->payload;
-		$this->attr = $message['message']['attr'];
-		$this->timestamp = $message['message']['timestamp'];
-		$this->key = $message['message']['key'];
-		$this->value = $message['message']['value'];
 	}
 
 }