kafka

Documentation

Index

• Constants
• func New(args *KafkaArgs, logger *zap.SugaredLogger) backend.Interface
• type KafkaArgs
  • func (ka *KafkaArgs) IsGSSAPI() (bool, error)
  • func (ka *KafkaArgs) Validate() error

Constants

const (
	BackendIDAttribute = "triggermeshbackendid"
)

Functions

func New

func New(args *KafkaArgs, logger *zap.SugaredLogger) backend.Interface

Types

type KafkaArgs

type KafkaArgs struct {
	Addresses []string `help:"Kafka addresses." env:"ADDRESSES"`
	Topic     string   `help:"Kafka topic." env:"TOPIC" default:"triggermesh"`

	GssServiceName        string `help:"GSSAPI service name." env:"GSSAPI_SERVICE_NAME"`
	GssRealm              string `help:"GSSAPI realm." env:"GSSAPI_REALM"`
	GssPrincipal          string `help:"GSSAPI principal." env:"GSSAPI_PRINCIPAL"`
	GssKeyTabPath         string `help:"GSSAPI keytab path." name:"gss-keytab-path" env:"GSSAPI_KEYTAB_PATH"`
	GssKerberosConfigPath string `help:"GSSAPI service name." env:"GSSAPI_KERBEROS_CONFIG_PATH"`

	ConsumerGroupPrefix string `help:"Kafka consumer group name." env:"CONSUMER_GROUP_PREFIX" default:"default"`
	// Instance at the Kafka consumer group. Copied from the InstanceName at the global args.
	Instance string `kong:"-"`

	TrackingIDEnabled bool `help:"Enables adding Kafka Offset as a CloudEvent attribute." env:"TRACKING_ID_ENABLED" default:"false"`
}

func (*KafkaArgs) IsGSSAPI

func (ka *KafkaArgs) IsGSSAPI() (bool, error)

func (*KafkaArgs) Validate

func (ka *KafkaArgs) Validate() error