KafkaBroker.prototype.subscribe - messaging-plugin/src/index.ts

method KafkaBroker.prototype.subscribe

Since 0.1.0



KafkaBroker.prototype.subscribe<T>(topic: string,
handler: MessageHandler<T>,
options?: SubscribeOptions
): Promise<ISubscription>

Subscribes to a topic using a consumer group.

Type Parameters

The message payload type



topic: string

The topic to subscribe to



handler: MessageHandler<T>

The handler to invoke for each message

optional



options: SubscribeOptions

Optional subscription options (queue for consumer group ID)

Promise<ISubscription>

The subscription handle

import { KafkaBroker } from "messaging-plugin/src/index.ts";