jobcloud · ruzakaranbol · Feb 21, 2022 · Jan 27, 2022 · Jan 27, 2022 · Jan 27, 2022
@@ -1,8 +1,8 @@
 version: 2.1
 
 orbs:
-  ci-caching: jobcloud/ci-caching@1.0.2
-  ci-php: jobcloud/ci-php@0.32
+  ci-caching: jobcloud/ci-caching@3.0
+  ci-php: jobcloud/ci-php@2.1
 
 workflows:
   test-php-kafka-lib:

@@ -22,7 +22,7 @@ test: pcov-disable
 
 static-analysis: pcov-disable
 	mkdir -p build/logs/phpstan
-	${PHPSTAN} analyse --no-progress --memory-limit=64
+	${PHPSTAN} analyse --no-progress
 
 update-dependencies:
 	composer update

@@ -18,7 +18,7 @@
   ],
   "require": {
     "php": "^7.3|^8.0",
-    "ext-rdkafka": "^4.0|^5.0",
+    "ext-rdkafka": "^4.0|^5.0|^6.0",
     "ext-json": "*"
   },
   "require-dev": {
@@ -44,5 +44,10 @@
     "branch-alias": {
       "dev-master": "2.0-dev"
     }
+  },
+  "config": {
+    "allow-plugins": {
+      "infection/extension-installer": false
+    }
   }
 }
@@ -31,7 +31,7 @@ RUN curl -sS https://getcomposer.org/installer | php -- --install-dir=/usr/bin -
 
 # PHP: Install php extensions
 RUN pecl channel-update pecl.php.net && \
-    pecl install rdkafka pcov && \
+    pecl install rdkafka-6.0.1 pcov && \
     docker-php-ext-install pcntl && \
     php-ext-enable rdkafka pcntl pcov
 

@@ -15,7 +15,6 @@
 
 final class KafkaConsumerRebalanceCallback
 {
-
     /**
      * @param RdKafkaConsumer $consumer
      * @param integer         $errorCode

@@ -12,7 +12,6 @@
 
 final class KafkaErrorCallback
 {
-
     /**
      * @param mixed   $kafka
      * @param integer $errorCode

@@ -11,7 +11,6 @@
 
 class KafkaConfiguration extends RdKafkaConf
 {
-
     /**
      * @var string[]
      */

@@ -20,7 +20,6 @@
 
 abstract class AbstractKafkaConsumer implements KafkaConsumerInterface
 {
-
     /**
      * @var KafkaConfiguration
      */

@@ -14,7 +14,6 @@
 
 final class KafkaConsumerBuilder implements KafkaConsumerBuilderInterface
 {
-
     public const CONSUMER_TYPE_LOW_LEVEL = 'low';
     public const CONSUMER_TYPE_HIGH_LEVEL = 'high';
 

@@ -8,7 +8,6 @@
 
 interface KafkaConsumerBuilderInterface
 {
-
     public const OFFSET_BEGINNING = RD_KAFKA_OFFSET_BEGINNING;
     public const OFFSET_END = RD_KAFKA_OFFSET_END;
     public const OFFSET_STORED = RD_KAFKA_OFFSET_STORED;

@@ -19,7 +19,6 @@
 
 final class KafkaHighLevelConsumer extends AbstractKafkaConsumer implements KafkaHighLevelConsumerInterface
 {
-
     /**
      * @var RdKafkaHighLevelConsumer
      */

@@ -19,7 +19,6 @@
 
 final class KafkaLowLevelConsumer extends AbstractKafkaConsumer implements KafkaLowLevelConsumerInterface
 {
-
     /**
      * @var RdKafkaLowLevelConsumer
      */

@@ -6,5 +6,4 @@
 
 interface KafkaLowLevelConsumerInterface extends KafkaConsumerInterface
 {
-
 }
@@ -6,7 +6,6 @@
 
 final class TopicSubscription implements TopicSubscriptionInterface
 {
-
     /**
      * @var string
      */

@@ -6,7 +6,6 @@
 
 interface TopicSubscriptionInterface
 {
-
     /**
      * @return string
      */

@@ -8,7 +8,6 @@
 
 class KafkaConsumerConsumeException extends \Exception
 {
-
     public const NOT_SUBSCRIBED_EXCEPTION_MESSAGE = 'This consumer is currently not subscribed';
 
     /**

@@ -6,5 +6,4 @@
 
 class KafkaConsumerEndOfPartitionException extends \Exception
 {
-
 }
@@ -6,5 +6,4 @@
 
 class KafkaConsumerTimeoutException extends \Exception
 {
-
 }
@@ -6,7 +6,6 @@
 
 abstract class AbstractKafkaMessage implements KafkaMessageInterface
 {
-
     /**
      * @var string|null
      */

@@ -9,7 +9,6 @@
 
 class JsonDecoder implements DecoderInterface
 {
-
     /**
      * @param KafkaConsumerMessageInterface $consumerMessage
      * @return KafkaConsumerMessageInterface

@@ -8,7 +8,6 @@
 
 final class NullDecoder implements DecoderInterface
 {
-
     /**
      * @param KafkaConsumerMessageInterface $consumerMessage
      * @return KafkaConsumerMessageInterface

@@ -14,7 +14,6 @@
 
 final class AvroEncoder implements AvroEncoderInterface
 {
-
     /**
      * @var AvroSchemaRegistryInterface
      */

@@ -8,7 +8,6 @@
 
 class JsonEncoder implements EncoderInterface
 {
-
     /**
      * @param KafkaProducerMessageInterface $producerMessage
      * @return KafkaProducerMessageInterface

@@ -8,7 +8,6 @@
 
 final class NullEncoder implements EncoderInterface
 {
-
     /**
      * @param KafkaProducerMessageInterface $producerMessage
      * @return KafkaProducerMessageInterface

@@ -6,7 +6,6 @@
 
 final class KafkaAvroSchema implements KafkaAvroSchemaInterface
 {
-
     /**
      * @var string
      */

@@ -6,7 +6,6 @@
 
 interface KafkaAvroSchemaInterface
 {
-
     public const LATEST_VERSION = -1;
 
     /**

@@ -6,7 +6,6 @@
 
 final class KafkaConsumerMessage extends AbstractKafkaMessage implements KafkaConsumerMessageInterface
 {
-
     /**
      * @var int
      */

@@ -6,7 +6,6 @@
 
 interface KafkaConsumerMessageInterface extends KafkaMessageInterface
 {
-
     /**
      * @return integer
      */

@@ -6,7 +6,6 @@
 
 interface KafkaMessageInterface
 {
-
     /**
      * Returns the message key or null if the message doesn't have a body
      * @return mixed

@@ -6,7 +6,6 @@
 
 final class KafkaProducerMessage extends AbstractKafkaMessage implements KafkaProducerMessageInterface
 {
-
     /**
      * @param string  $topicName
      * @param integer $partition

@@ -6,7 +6,6 @@
 
 interface KafkaProducerMessageInterface extends KafkaMessageInterface
 {
-
     /**
      * @param string  $topicName
      * @param integer $partition

@@ -18,7 +18,6 @@
 
 final class KafkaProducer implements KafkaProducerInterface
 {
-
     /**
      * @var RdKafkaProducer
      */

@@ -10,7 +10,6 @@
 
 interface KafkaProducerInterface
 {
-
     /**
      * @param KafkaProducerMessageInterface $message
      * @param boolean $autoPoll
-Original file line number
+Diff line change
@@ Expand Up / @@ -15,7 +15,6 @@ @@
     final class KafkaConsumerRebalanceCallback
     {
         /**
          * @param RdKafkaConsumer $consumer
          * @param integer         $errorCode
@@ Expand Down @@
Original file line number	Diff line number	Diff line change
Expand Up		@@ -6,5 +6,4 @@

		interface KafkaLowLevelConsumerInterface extends KafkaConsumerInterface
		{

		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -6,5 +6,4 @@

		class KafkaConsumerEndOfPartitionException extends \Exception
		{

		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -6,5 +6,4 @@

		class KafkaConsumerTimeoutException extends \Exception
		{

		}