Merge branch 'master' into feat/JMP-2328/possibility-to-decode-later

src/Consumer/AbstractKafkaConsumer.php

@@ -81,13 +81,14 @@ public function getConfiguration(): array
      * Consumes a message and returns it
      * In cases of errors / timeouts an exception is thrown
      *
+     * @param integer $timeoutMs
      * @param boolean $autoDecode
      * @return KafkaConsumerMessageInterface
      * @throws KafkaConsumerConsumeException
      * @throws KafkaConsumerEndOfPartitionException
      * @throws KafkaConsumerTimeoutException
      */
-    public function consume(bool $autoDecode = true): KafkaConsumerMessageInterface
+    public function consume(int $timeoutMs = 10000, bool $autoDecode = true): KafkaConsumerMessageInterface
     {
         if (false === $this->isSubscribed()) {
             throw new KafkaConsumerConsumeException(KafkaConsumerConsumeException::NOT_SUBSCRIBED_EXCEPTION_MESSAGE);

src/Consumer/KafkaConsumerInterface.php

@@ -39,10 +39,11 @@ public function isSubscribed(): bool;
      * Consumes a message and returns it
      * In cases of errors / timeouts a KafkaConsumerConsumeException is thrown
      *
+     * @param integer $timeoutMs
      * @param boolean $autoDecode
      * @return KafkaConsumerMessageInterface
      */
-    public function consume(bool $autoDecode = true): KafkaConsumerMessageInterface;
+    public function consume(int $timeoutMs = 10000, bool $autoDecode = true): KafkaConsumerMessageInterface;
 
     /**
      * Decode consumer message