Class KafkaProducer

Kafka producer client, abstraction on top of HighLevelProducer from node-rdkafka

Hierarchy

KafkaProducer

Index

Methods

Methods

registerKeySchema

registerKeySchema(outputTopic: string, keySchema: object): Promise<object>

- Defined in producer.ts:78
Parameters
- outputTopic: string
- keySchema: object
Returns Promise<object>

registerSchema

registerSchema(outputTopic: string, valueSchema: object, keySchema?: undefined | object): Promise<object>

- Defined in producer.ts:88
Parameters
- outputTopic: string
- valueSchema: object
- Optional keySchema: undefined | object
Returns Promise<object>

registerValueSchema

registerValueSchema(outputTopic: string, valueSchema: object): Promise<object>

- Defined in producer.ts:83
Parameters
- outputTopic: string
- valueSchema: object
Returns Promise<object>

sendMessage

sendMessage(options: KafkaProducerRequest): Promise<unknown>

- Defined in producer.ts:59
Parameters
- options: KafkaProducerRequest
Returns Promise<unknown>

Static init

init(schemaClient: Schema, options: KafkaClientOptions): Promise<KafkaProducer>

- Defined in producer.ts:26
Parameters
- schemaClient: Schema
- options: KafkaClientOptions
Returns Promise<KafkaProducer>

Generated using TypeDoc