Interface KafkaClientLike

Minimal Kafka client factory shape accepted by the transport.

interface KafkaClientLike {
    admin(): KafkaAdminLike;
    consumer(config: unknown): KafkaConsumerLike;
    producer(config?: unknown): KafkaProducerLike;
}

Index

Methods

admin consumer producer

Methods

admin

admin(): KafkaAdminLike
Create an admin client instance.

Returns KafkaAdminLike
- Defined in packages/kkrpc/src/transports/kafka.ts:104

consumer

consumer(config: unknown): KafkaConsumerLike
Create a consumer instance.
Parameters
- config: unknown
Returns KafkaConsumerLike
- Defined in packages/kkrpc/src/transports/kafka.ts:102

producer

producer(config?: unknown): KafkaProducerLike
Create a producer instance.
Parameters
- Optionalconfig: unknown
Returns KafkaProducerLike
- Defined in packages/kkrpc/src/transports/kafka.ts:100