startup_kafka

type KafkaOptions struct {
	Addresses          []string `` /* 155-byte string literal not displayed */
	DefaultReplication int16    `long:"kafka-replication" default:"1" validate:"min=1" description:"Default replication factor for topic creation."`

	Inputs struct {
		// You can provide an extra kafka config to override the
		// default config.
		KafkaConfig *sarama.Config

		// You could specify a topics function to automatically create topics
		// with this kafka instance
		Topics kafka.TopicsFunc
	}
	// contains filtered or unexported fields
}