kafka

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"`
}