add strict to rdkafka transport.

Author: makasim

pkg/rdkafka/JsonSerializer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 class JsonSerializer implements Serializer

pkg/rdkafka/RdKafkaConnectionFactory.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\PsrConnectionFactory;

pkg/rdkafka/RdKafkaConsumer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\InvalidMessageException;

pkg/rdkafka/RdKafkaContext.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\InvalidDestinationException;

pkg/rdkafka/RdKafkaMessage.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\PsrMessage;

pkg/rdkafka/RdKafkaProducer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\InvalidDestinationException;

pkg/rdkafka/RdKafkaTopic.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 use Interop\Queue\PsrQueue;

pkg/rdkafka/Serializer.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 interface Serializer

pkg/rdkafka/SerializerAwareTrait.php

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 namespace Enqueue\RdKafka;
 
 trait SerializerAwareTrait

pkg/rdkafka/Tests/RdKafkaConsumerTest.php

@@ -132,6 +132,7 @@ public function testShouldSubscribeOnFirstReceiveOnly()
     public function testShouldAssignWhenOffsetIsSet()
     {
         $destination = new RdKafkaTopic('dest');
+        $destination->setPartition(1);
 
         $kafkaMessage = new Message();
         $kafkaMessage->err = RD_KAFKA_RESP_ERR__TIMED_OUT;