mateusjunges/laravel-kafka
Laravel Kafka makes it easy to produce and consume Kafka messages in Laravel with a clean, expressive API and improved testability. Build producers and consumers quickly, integrate with your app workflows, and avoid painful Kafka testing setups.
To assert that messages were published on a given topic a given number of times, you can use the assertPublishedOnTimes method:
use PHPUnit\Framework\TestCase;
use Junges\Kafka\Facades\Kafka;
use Junges\Kafka\Message\Message;
class MyTest extends TestCase
{
public function testWithSpecificTopic()
{
Kafka::fake();
Kafka::publish('broker')
->onTopic('topic')
->withHeaders(['key' => 'value'])
->withBodyKey('key', 'value');
Kafka::publish('broker')
->onTopic('topic')
->withHeaders(['key' => 'value'])
->withBodyKey('key', 'value');
Kafka::assertPublishedOnTimes('some-kafka-topic', 2);
}
}
<x-sponsors.request-sponsor/>
How can I help you explore Laravel packages today?