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

method KafkaBroker.prototype.subscribeWithHeaders



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

Subscribes through the header-aware internal path. @internal

Type Parameters



topic: string



handler: MessageHandler<T>

optional



options: SubscribeOptions

Promise<ISubscription>