basalt / queue-kafka/src / KafkaConsumer

Interface: KafkaConsumer

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

Methods

connect()

> connect(): Promise<void>

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

Returns

Promise<void>

---

disconnect()

> disconnect(): Promise<void>

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

Returns

Promise<void>

---

run()

> run(config): Promise<void>

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

Parameters

config

eachMessage

(payload) => Promise<void>

partitionsConsumedConcurrently?

number

Returns

Promise<void>

---

subscribe()

> subscribe(subscription): Promise<void>

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

Parameters

subscription

fromBeginning?

boolean

topic

string

Returns

Promise<void>