events.v1alpha1.kafkaEventSource
Index
fn withJsonBody(jsonBody)
fn withLimitEventsPerSecond(limitEventsPerSecond)
fn withMetadata(metadata)
fn withMetadataMixin(metadata)
fn withPartition(partition)
fn withTopic(topic)
fn withUrl(url)
fn withVersion(version)
obj connectionBackoff
obj consumerGroup
obj sasl
obj tls
Fields
fn withJsonBody
withJsonBody(jsonBody)
fn withLimitEventsPerSecond
withLimitEventsPerSecond(limitEventsPerSecond)
fn withMetadata
withMetadata(metadata)
fn withMetadataMixin
withMetadataMixin(metadata)
Note: This function appends passed data to existing values
fn withPartition
withPartition(partition)
fn withTopic
withTopic(topic)
fn withUrl
withUrl(url)
fn withVersion
withVersion(version)
obj connectionBackoff
fn connectionBackoff.withSteps
withSteps(steps)
obj connectionBackoff.duration
fn connectionBackoff.duration.withInt64Val
withInt64Val(int64Val)
fn connectionBackoff.duration.withStrVal
withStrVal(strVal)
fn connectionBackoff.duration.withType
withType(type)
obj connectionBackoff.factor
"Amount represent a numeric amount."
fn connectionBackoff.factor.withValue
withValue(value)
obj connectionBackoff.jitter
"Amount represent a numeric amount."
fn connectionBackoff.jitter.withValue
withValue(value)
obj consumerGroup
fn consumerGroup.withGroupName
withGroupName(groupName)
fn consumerGroup.withOldest
withOldest(oldest)
fn consumerGroup.withRebalanceStrategy
withRebalanceStrategy(rebalanceStrategy)
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"