cap-nodejs

CAP Node.js API


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

Interface: ProducerConfig

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

Properties

acks?

optional acks?: number

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


allowAutoTopicCreation?

optional allowAutoTopicCreation?: boolean

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


compression?

optional compression?: CompressionTypes

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


idempotent?

optional idempotent?: boolean

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


logger?

optional logger?: Logger

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


logLevel?

optional logLevel?: logLevel

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


maxInFlightRequests?

optional maxInFlightRequests?: number

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


metadataMaxAge?

optional metadataMaxAge?: number

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


retry?

optional retry?: RetryOptions

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


timeout?

optional timeout?: number

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


transactionalId?

optional transactionalId?: string

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


transactionTimeout?

optional transactionTimeout?: number

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