startup_kafka

Documentation

Index

• type KafkaOptions
  • func (opts *KafkaOptions) KafkaClient(clientId string) sarama.Client

Types

type KafkaOptions

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."`
	DisableTls         bool     `long:"kafka-disable-tls" description:"Do not enable tls."`

	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
}

func (*KafkaOptions) KafkaClient

func (opts *KafkaOptions) KafkaClient(clientId string) sarama.Client