Assert nothing published
You can assert that nothing was published at all, using the assertNothingPublished
:
use PHPUnit\Framework\TestCase; use Junges\Kafka\Facades\Kafka; use Junges\Kafka\Message\Message; class MyTest extends TestCase { public function testWithSpecificTopic() { Kafka::fake(); if (false) { $producer = Kafka::publish('broker') ->onTopic('some-kafka-topic') ->withHeaders(['key' => 'value']) ->withBodyKey('key', 'value'); $producer->send(); } Kafka::assertNothingPublished(); } }