diff --git a/Kafka/Message.php b/Kafka/Message.php index e57d1acb..701d0ba0 100644 --- a/Kafka/Message.php +++ b/Kafka/Message.php @@ -26,6 +26,7 @@ class Message implements ConsumerInterface, PipeMessage public function process(): void { // TODO: Implement process() method. + var_dump($this->struct); } }