Skip to content

events.v1alpha1.kafkaTrigger

"KafkaTrigger refers to the specification of the Kafka trigger."

Index

Fields

fn withCompress

withCompress(compress)

fn withFlushFrequency

withFlushFrequency(flushFrequency)

fn withParameters

withParameters(parameters)

"Parameters is the list of parameters that is applied to resolved Kafka trigger object."

fn withParametersMixin

withParametersMixin(parameters)

"Parameters is the list of parameters that is applied to resolved Kafka trigger object."

Note: This function appends passed data to existing values

fn withPartition

withPartition(partition)

"Partition to write data to."

fn withPartitioningKey

withPartitioningKey(partitioningKey)

"The partitioning key for the messages put on the Kafka topic.\nDefaults to broker url.\n+optional."

fn withPayload

withPayload(payload)

"Payload is the list of key-value extracted from an event payload to construct the request payload."

fn withPayloadMixin

withPayloadMixin(payload)

"Payload is the list of key-value extracted from an event payload to construct the request payload."

Note: This function appends passed data to existing values

fn withRequiredAcks

withRequiredAcks(requiredAcks)

"RequiredAcks used in producer to tell the broker how many replica acknowledgements\nDefaults to 1 (Only wait for the leader to ack).\n+optional."

fn withTopic

withTopic(topic)

fn withUrl

withUrl(url)

"URL of the Kafka broker, multiple URLs separated by comma."

fn withVersion

withVersion(version)

obj sasl

fn sasl.withMechanism

withMechanism(mechanism)

obj sasl.password

"SecretKeySelector selects a key of a Secret."

fn sasl.password.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn sasl.password.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn sasl.password.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj sasl.user

"SecretKeySelector selects a key of a Secret."

fn sasl.user.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn sasl.user.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn sasl.user.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj tls

"TLSConfig refers to TLS configuration for a client."

fn tls.withCaCertPath

withCaCertPath(caCertPath)

fn tls.withClientCertPath

withClientCertPath(clientCertPath)

fn tls.withClientKeyPath

withClientKeyPath(clientKeyPath)

obj tls.caCertSecret

"SecretKeySelector selects a key of a Secret."

fn tls.caCertSecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn tls.caCertSecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn tls.caCertSecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj tls.clientCertSecret

"SecretKeySelector selects a key of a Secret."

fn tls.clientCertSecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn tls.clientCertSecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn tls.clientCertSecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj tls.clientKeySecret

"SecretKeySelector selects a key of a Secret."

fn tls.clientKeySecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn tls.clientKeySecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn tls.clientKeySecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"