From b46234858cea7535a73e4fd556b3c5b9b4228fca Mon Sep 17 00:00:00 2001 From: Alexander Kozienko Date: Fri, 2 Nov 2018 09:33:22 +0200 Subject: [PATCH] fix tests 08 --- pkg/rdkafka/Tests/RdKafkaConsumerTest.php | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/pkg/rdkafka/Tests/RdKafkaConsumerTest.php b/pkg/rdkafka/Tests/RdKafkaConsumerTest.php index 77a949c15..e79a51df0 100644 --- a/pkg/rdkafka/Tests/RdKafkaConsumerTest.php +++ b/pkg/rdkafka/Tests/RdKafkaConsumerTest.php @@ -50,7 +50,7 @@ public function testShouldReceiveFromQueueAndReturnNullIfNoMessageInQueue() $kafkaConsumer = $this->createKafkaConsumerMock(); $kafkaConsumer ->expects($this->once()) - ->method('assign') + ->method('subscribe') ; $kafkaConsumer ->expects($this->once()) @@ -94,6 +94,8 @@ public function testShouldPassProperlyConfiguredTopicPartitionOnAssign() $this->createSerializerMock() ); + $consumer->setOffset(12345); + $consumer->receive(1000); $consumer->receive(1000); $consumer->receive(1000); @@ -109,7 +111,7 @@ public function testShouldSubscribeOnFirstReceiveOnly() $kafkaConsumer = $this->createKafkaConsumerMock(); $kafkaConsumer ->expects($this->once()) - ->method('assign') + ->method('subscribe') ; $kafkaConsumer ->expects($this->any()) @@ -139,7 +141,7 @@ public function testThrowOnOffsetChangeAfterSubscribing() $kafkaConsumer = $this->createKafkaConsumerMock(); $kafkaConsumer ->expects($this->once()) - ->method('assign') + ->method('subscribe') ; $kafkaConsumer ->expects($this->any()) @@ -174,7 +176,7 @@ public function testShouldReceiveFromQueueAndReturnMessageIfMessageInQueue() $kafkaConsumer = $this->createKafkaConsumerMock(); $kafkaConsumer ->expects($this->once()) - ->method('assign') + ->method('subscribe') ; $kafkaConsumer ->expects($this->once())