method KafkaBroker.prototype.publishWithHeaders
KafkaBroker.prototype.publishWithHeaders<T>(
topic: string,
message: T,
headers: Readonly<Record<string, string>>
): Promise<void>

Publishes a message with framework-owned transport headers. @internal

Type Parameters

Parameters

topic: string
message: T
headers: Readonly<Record<string, string>>

Return Type

Promise<void>

Usage

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