K
Laravel Kafka
Docs
Blog
GitHub
Search
⌘K
Login with GitHub
Login
Docs for version
selected
v3.0
v2.13
v2.12
v2.11
v2.10
v2.9
v2.8
v1.13
Introduction
Requirements
Installation and Setup
Questions and issues
Changelog
Upgrade guide
Example docker-compose file
Producing messages
Producing messages
Configuring your kafka producer
Configuring message payload
Custom serializers
Publishing to kafka
Consuming messages
Creating a kafka consumer
Subscribing to kafka topics
Using regex to subscribe to kafka topics
Assigning consumers to a topic partition
Consuming messages from specific offsets
Consumer groups
Partition Discovery and Dynamic Assignment
Message handlers
Configuring consumer options
Custom deserializers
Consuming messages
Class structure
Queueable handlers
Advanced usage
Replacing the default serializer/deserializer
Graceful shutdown
SASL Authentication
Custom Committers
Manual Commit
Middlewares
Stop consumer after last messages
Stop consumer on demand
Writing custom loggers
Before and after callbacks
Setting global configurations
Sending multiple messages with the same producer
Testing
Kafka fake
Assert Published
Assert published On
Assert nothing published
Assert published times
Assert published on times
Mocking your kafka consumer
Consuming messages
Sponsors
E
a
syC
a
l
Your logo here?
K
Laravel Kafka
Search
Docs for version
selected
v3.0
v2.13
v2.12
v2.11
v2.10
v2.9
v2.8
v1.13
Introduction
Requirements
Installation and Setup
Questions and issues
Changelog
Upgrade guide
Example docker-compose file
Producing messages
Producing messages
Configuring your kafka producer
Configuring message payload
Custom serializers
Publishing to kafka
Consuming messages
Creating a kafka consumer
Subscribing to kafka topics
Using regex to subscribe to kafka topics
Assigning consumers to a topic partition
Consuming messages from specific offsets
Consumer groups
Partition Discovery and Dynamic Assignment
Message handlers
Configuring consumer options
Custom deserializers
Consuming messages
Class structure
Queueable handlers
Advanced usage
Replacing the default serializer/deserializer
Graceful shutdown
SASL Authentication
Custom Committers
Manual Commit
Middlewares
Stop consumer after last messages
Stop consumer on demand
Writing custom loggers
Before and after callbacks
Setting global configurations
Sending multiple messages with the same producer
Testing
Kafka fake
Assert Published
Assert published On
Assert nothing published
Assert published times
Assert published on times
Mocking your kafka consumer
Search
⌘
K