Skip to content

events.v1alpha1.kafkaEventSource

Index

Fields

fn withConfig

withConfig(config)

"Yaml format Sarama config for Kafka connection.\nIt follows the struct of sarama.Config. See https://github.com/Shopify/sarama/blob/main/config.go\ne.g.\n\nconsumer:\n fetch:\n min: 1\nnet:\n MaxOpenRequests: 5\n\n+optional"

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 filter

fn filter.withExpression

withExpression(expression)

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.withInsecureSkipVerify

withInsecureSkipVerify(insecureSkipVerify)

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"