startup_kafka

type KafkaOptions struct {
	// Inputs holds values that are not parsed from the command line but injected
	// by the caller before Initialize runs.
	Inputs struct {
		// Set topics to automatically create topics on startup
		Topics TopicsFunc

		// Additional configuration options to apply to all clients
		DefaultConfig kafka.ConfigMap
	}

	KafkaAddresses        []string `` /* 175-byte string literal not displayed */
	KafkaConsumerGroup    string   `` /* 158-byte string literal not displayed */
	KafkaOffsetReset      string   `` /* 147-byte string literal not displayed */
	KafkaReplication      int16    `` /* 132-byte string literal not displayed */
	KafkaSecurityProtocol string   `` /* 138-byte string literal not displayed */
	KafkaProperties       []string `long:"kafka-property" env:"KAFKA_PROPERTY" description:"Rdkafka properties in key=value format"`

	// schema registry is not really kafka, but it is only used with kafka,
	// so I guess it is okay to put it here.
	ConfluentURL string `` /* 159-byte string literal not displayed */
}

type Topic struct {
	Name              string
	NumPartitions     int32
	ReplicationFactor int16

	// https://docs.confluent.io/platform/current/installation/configuration/topic-configs.html
	Config map[string]string
}

type Topics []Topic

type TopicsFunc func(replicationFactor int16) Topics