Notice: Trying to get property of non-object in /var/www/html/Kafka/consumer.php on line 9

[Abdelrahman Mohamed]

1 <?php

2 $rk = new RdKafka\Consumer();

3 $rk->setLogLevel(LOG_DEBUG);

4 $rk->addBrokers("192.168.1.47");

5 $topic = $rk->newTopic("Test");

6 $topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);

7 while (true) {

8   $msg = $topic->consume(0, 1000);

9   if ($msg->err) {

10        echo $msg->errstr(), "\n";

11        break;

12    } else {

13        echo $msg->payload, "\n";

14 echo "<br>";

15    }

16 }