test improvements

nick-zh · nick-zh · commit b1a0bbc1b2ca · 2020-10-05T21:14:06.000+02:00
diff --git a/pkg/rdkafka/Tests/Spec/RdKafkaSendToAndReceiveFromTopicTest.php b/pkg/rdkafka/Tests/Spec/RdKafkaSendToAndReceiveFromTopicTest.php
@@ -30,7 +30,8 @@ public function test()
 
         $context->createProducer()->send($topic, $context->createMessage($expectedBody));
 
-        $message = $consumer->receive(10000); // 10 sec
+        // Initial balancing can take some time, so we want to make sure the timeout is high enough
+        $message = $consumer->receive(15000); // 15 sec
 
         $this->assertInstanceOf(Message::class, $message);
         $consumer->acknowledge($message);
@@ -47,7 +48,7 @@ protected function createContext()
                 'enable.auto.commit' => 'false',
             ],
             'topic' => [
-                'auto.offset.reset' => 'beginning',
+                'auto.offset.reset' => 'earliest',
             ],
         ];
 
