basalt / queue-kafka/src / KafkaClient

Interface: KafkaClient

Defined in: queue-kafka/src/index.ts:10

The subset of a kafkajs client this driver uses.

Methods

consumer()

> consumer(config): KafkaConsumer

Defined in: queue-kafka/src/index.ts:12

Parameters

config

groupId

string

Returns

KafkaConsumer

---

producer()

> producer(): KafkaProducer

Defined in: queue-kafka/src/index.ts:11

Returns

KafkaProducer