This extension supports working with Apache Kafka.
-
Install library
composer require lamoda/codeception-kafka
-
Create message serializer for your data transfer object
namespace Tests\KafkaModule;
use App\EventBus\DtoInterface;
use Lamoda\Codeception\Extension\MessageSerializer\MessageSerializerInterface;
class AcmeMessageSerializer implements MessageSerializerInterface
{
public function serialize($dto): string
{
if (!$dto instanceif DtoInterface) {
throw new \RuntimeException('This value must be an ' . DtoInterface::class);
}
$message = json_encode($dto->toArray());
if (!is_string($message)) {
throw new \RuntimeException(json_last_error(), json_last_error_msg());
}
return $message;
}
}
The default message serializer is Lamoda\Codeception\Extension\MessageSerializer\ArrayMessageSerializer.
- Include to suite and configure
modules: enabled: - \Lamoda\Codeception\Extension\KafkaModule serializer: 'Tests\KafkaModule\AcmeMessageSerializer' config: metadata.broker.list: '192.168.99.100:9092' group.id: 'group_for_tests' topic_config: offset.store.sync.interval.ms: '0' auto.commit.interval.ms: '500' auto.offset.reset: 'smallest'
make php-cs-check make php-cs-fix
Unit
make test-unit