Interface ConsumerConfig

ackTimeoutMs?: number

autoAckOldestChunkedMessageOnQueueFull?: number

batchIndexAckEnabled?: boolean

batchReceivePolicy?: ConsumerBatchReceivePolicy

consumerName?: string

cryptoFailureAction?: ConsumerCryptoFailureAction

deadLetterPolicy?: DeadLetterPolicy

keySharedPolicy?: KeySharedPolicy

listener?: ((message: Message, consumer: Consumer) => void)

maxPendingChunkedMessage?: number

nAckRedeliverTimeoutMs?: number

privateKeyPath?: string

properties?: {
    [key: string]: string;
}

readCompacted?: boolean

receiverQueueSize?: number

receiverQueueSizeAcrossPartitions?: number

regexSubscriptionMode?: RegexSubscriptionMode

schema?: SchemaInfo

subscription: string

subscriptionInitialPosition?: InitialPosition

subscriptionType?: SubscriptionType

topic?: string

topics?: string[]

topicsPattern?: string