KafkaTransportOptions
Options for creating a Kafka-backed pubsub transport.
Properties
Section titled “Properties”adminConfig?
Section titled “adminConfig?”
optionaladminConfig?:AdminConstructorConfig
Optional Kafka admin constructor config.
client
Section titled “client”client:
Kafka
@confluentinc/kafka-javascript Kafka client.
consumerConfig?
Section titled “consumerConfig?”
optionalconsumerConfig?:KafkaConsumerOptions
Optional Kafka consumer constructor config.
defaultSource?
Section titled “defaultSource?”
optionaldefaultSource?:string
Default CloudEvent source for publishers using this transport.
interceptors?
Section titled “interceptors?”
optionalinterceptors?:PubSubInterceptor[]
Optional interceptors for transport operations.
producerConfig?
Section titled “producerConfig?”
optionalproducerConfig?:ProducerConstructorConfig
Optional Kafka producer constructor config.
publishTimeoutMs?
Section titled “publishTimeoutMs?”
optionalpublishTimeoutMs?:number
Optional timeout for Kafka producer sends in milliseconds.
scheduler?
Section titled “scheduler?”
optionalscheduler?:PubSubScheduler
Optional scheduler used for durable notBefore publish and delayed retry.
Immediate publish/subscribe does not require a scheduler. If a publish call
provides notBefore, or a handler returns ctx.retry({ delay }), the
transport throws unless a scheduler was supplied.
signal?
Section titled “signal?”
optionalsignal?:AbortSignal
Optional signal that closes this transport when aborted.