PHP Libraries › mateusjunges › laravel-kafka Laravel Kafka package offering seamless integration for efficient messaging between microservices and applications.
Package Description Laravel Kafka is a comprehensive PHP library that simplifies Kafka integration into Laravel applications, enabling robust communication between services. By leveraging Kafka's distributed messaging system, developers gain scalability, fault tolerance, and real-time data processing capabilities. The library provides streamlined configuration, convenient producer and consumer APIs, and extensive documentation for seamless implementation.
Classes: Junges\Kafka\Commit\RetryableCommitter Junges\Kafka\Commit\BatchCommitter Junges\Kafka\Commit\NativeSleeper Junges\Kafka\Commit\VoidCommitter Junges\Kafka\Commit\SeekToCurrentErrorCommitter Junges\Kafka\Commit\DefaultCommitterFactory Junges\Kafka\Commit\Committer Junges\Kafka\Producers\Builder Junges\Kafka\Producers\Producer Junges\Kafka\Contracts\Sleeper Junges\Kafka\Contracts\AvroMessageDeserializer Junges\Kafka\Contracts\ConsumerBuilder Junges\Kafka\Contracts\KafkaAvroSchemaRegistry Junges\Kafka\Contracts\CommitterFactory Junges\Kafka\Contracts\AvroMessageSerializer Junges\Kafka\Contracts\MessageProducer Junges\Kafka\Contracts\InteractsWithConfigCallbacks Junges\Kafka\Contracts\Producer Junges\Kafka\Contracts\AvroSchemaRegistry Junges\Kafka\Contracts\Consumer Junges\Kafka\Contracts\RetryStrategy Junges\Kafka\Contracts\ContextAware Junges\Kafka\Contracts\MessageSerializer Junges\Kafka\Contracts\Handler Junges\Kafka\Contracts\Logger Junges\Kafka\Contracts\KafkaMessage Junges\Kafka\Contracts\Manager Junges\Kafka\Contracts\MessageConsumer Junges\Kafka\Contracts\ProducerMessage Junges\Kafka\Contracts\MessageDeserializer Junges\Kafka\Contracts\Middleware Junges\Kafka\Contracts\ConsumerMessage Junges\Kafka\Contracts\Committer Junges\Kafka\Support\InfiniteTimer Junges\Kafka\Support\Testing\Fakes\ProducerFake Junges\Kafka\Support\Testing\Fakes\BuilderFake Junges\Kafka\Support\Testing\Fakes\KafkaFake Junges\Kafka\Support\Testing\Fakes\ProducerBuilderFake Junges\Kafka\Support\Testing\Fakes\ConsumerFake Junges\Kafka\Support\Timer Junges\Kafka\Message\Registry\AvroSchemaRegistry Junges\Kafka\Message\Serializers\JsonSerializer Junges\Kafka\Message\Serializers\AvroSerializer Junges\Kafka\Message\ConsumedMessage Junges\Kafka\Message\Message Junges\Kafka\Message\KafkaAvroSchema Junges\Kafka\Message\Deserializers\JsonDeserializer Junges\Kafka\Message\Deserializers\AvroDeserializer Junges\Kafka\Console\Commands\KafkaConsumer\Options Junges\Kafka\Console\Commands\ConsumerCommand Junges\Kafka\Console\Commands\RestartConsumersCommand Junges\Kafka\Consumers\DispatchQueuedHandler Junges\Kafka\Consumers\Builder Junges\Kafka\Consumers\Consumer Junges\Kafka\Consumers\CallableConsumer Junges\Kafka\MessageCounter Junges\Kafka\Exceptions\ConsumerException Junges\Kafka\Exceptions\SchemaRegistryException Junges\Kafka\Exceptions\MessageIdNotSet Junges\Kafka\Exceptions\Serializers\AvroSerializerException Junges\Kafka\Exceptions\ContextAwareException Junges\Kafka\Exceptions\CouldNotPublishMessage Junges\Kafka\Exceptions\Transactions\TransactionFatalErrorException Junges\Kafka\Exceptions\Transactions\TransactionShouldBeRetriedException Junges\Kafka\Exceptions\Transactions\TransactionShouldBeAbortedException Junges\Kafka\Exceptions\LaravelKafkaException Junges\Kafka\Events\CouldNotPublishMessage Junges\Kafka\Events\PublishingMessage Junges\Kafka\Events\MessagePublished Junges\Kafka\Events\StartedConsumingMessage Junges\Kafka\Events\MessageSentToDLQ Junges\Kafka\Events\MessageConsumed Junges\Kafka\Logger Junges\Kafka\Facades\Kafka Junges\Kafka\Providers\LaravelKafkaServiceProvider Junges\Kafka\Retryable Junges\Kafka\Handlers\RetryStrategies\DefaultRetryStrategy Junges\Kafka\Handlers\RetryableHandler Junges\Kafka\Config\Sasl Junges\Kafka\Config\Config Junges\Kafka\Factory Junges\Kafka\AbstractMessage Junges\Kafka\Concerns\HandleConsumedMessage Junges\Kafka\Concerns\InteractsWithConfigCallbacks Junges\Kafka\Concerns\ManagesTransactions Junges\Kafka\Concerns\PrepareMiddlewares Close Previous Versions Code Integration Example Make sure to include the correct namespace and class paths for proper usage.
<?php
// Example from PHPlibraries.com
require_once 'libs/mateusjunges/laravel-kafka/2.10.1/loader.php';
require_once 'libs/php-enqueue/enqueue/0.10.27/loader.php';
require_once 'libs/rdkafka/rdkafka/{lib_version}/loader.php';
use MateusJunges\LaravelKafka\KafkaManager;
use Enqueue\RdKafka\RdKafkaContext;
$obj = new KafkaManager();
echo '✅ Test OK: ' . get_class($obj);
?>Report a broken download or code We aim to make using PHP packages easier without Composer. If something doesn't work, let us know — we'll fix it promptly.
Community Discussion Ask questions, share tips, or report issues below.