KafkaMessagingOptions - messaging-plugin/src/index.ts - Setu-TS documentation

interface KafkaMessagingOptions

extends MessagingCommonOptions

Since 0.1.0

Kafka arm.

Properties



broker: "kafka"

optional



brokers: readonly string[]

optional



client: IKafkaFactory

optional



clientId: string

optional



defaultQueue: string

optional



replyTopic: string

Usage

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