Subscribing to kafka topics
With a consumer created, you can subscribe to a kafka topic using the subscribe
method:
use Junges\Kafka\Facades\Kafka; $consumer = Kafka::consumer()->subscribe('topic');
Of course, you can subscribe to more than one topic at once, either using an array of topics or specifying one by one:
use Junges\Kafka\Facades\Kafka; $consumer = Kafka::consumer()->subscribe('topic-1', 'topic-2', 'topic-n'); // Or, using array: $consumer = Kafka::consumer()->subscribe([ 'topic-1', 'topic-2', 'topic-n' ]);