createKafkaScheduler
createKafkaScheduler(
options):PubSubScheduler
Defined in: packages/pubsub/src/kafka/scheduler.ts:62
Create a self-contained Kafka scheduler that can be shared across transports.
Parameters
Section titled “Parameters”options
Section titled “options”CreateKafkaSchedulerOptions
Returns
Section titled “Returns”PubSubScheduler