Interface ConsumerConfig

ackTimeoutMs?: number

autoAckOldestChunkedMessageOnQueueFull?: number

consumerName?: string

cryptoFailureAction?: ConsumerCryptoFailureAction

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

maxPendingChunkedMessage?: number

nAckRedeliverTimeoutMs?: number

privateKeyPath?: string

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

readCompacted?: boolean

receiverQueueSize?: number

receiverQueueSizeAcrossPartitions?: number

subscription: string

subscriptionInitialPosition?: InitialPosition

subscriptionType?: SubscriptionType

topic?: string

topics?: string[]

topicsPattern?: string