cap-nodejs

CAP Node.js API

---

CAP Node.js API / cap-transport-kafka/src / ConsumerConfig

Interface: ConsumerConfig

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:223

Properties

allowAutoTopicCreation?

optional allowAutoTopicCreation?: boolean

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:236

---

autoCommit?

optional autoCommit?: boolean

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:241

---

autoCommitInterval?

optional autoCommitInterval?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:242

---

fromBeginning?

optional fromBeginning?: boolean

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:240

---

groupId

groupId: string

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:224

---

heartbeatInterval?

optional heartbeatInterval?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:228

---

logger?

optional logger?: Logger

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:235

---

logLevel?

optional logLevel?: logLevel

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:234

---

maxBytes?

optional maxBytes?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:231

---

maxBytesPerPartition?

optional maxBytesPerPartition?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:229

---

maxInFlightRequests?

optional maxInFlightRequests?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:237

---

maxWaitTimeInMs?

optional maxWaitTimeInMs?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:232

---

metadataMaxAge?

optional metadataMaxAge?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:225

---

minBytes?

optional minBytes?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:230

---

partitionAssigners?

optional partitionAssigners?: PartitionAssigners[]

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:243

---

partitionAssignors?

optional partitionAssignors?: PartitionAssignors[]

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:244

---

rackId?

optional rackId?: string

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:239

---

readUncommitted?

optional readUncommitted?: boolean

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:238

---

rebalanceTimeout?

optional rebalanceTimeout?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:227

---

retry?

optional retry?: RetryOptions

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:233

---

sessionTimeout?

optional sessionTimeout?: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:226

This site is open source. Improve this page.