kafka

Documentation

Index

• type Config
• type Kafka
  • func New(c *Config) (*Kafka, error)
• type SASL
• type TLS

Types

type Config

type Config struct {
	Brokers []string    `mapstructure:"brokers"`
	TLS     *TLS        `mapstructure:"tls"`
	SASL    *SASL       `mapstructure:"sasl"`
	SSH     *ssh.Config `mapstructure:"ssh_tunnel"`
}

type Kafka

type Kafka struct {
	sarama.Client
}

func New

func New(c *Config) (*Kafka, error)

type SASL

type SASL struct {
	Mechanism string `mapstructure:"mechanism"`
	Username  string `mapstructure:"username"`
	Password  string `mapstructure:"password"`
}

type TLS

type TLS struct {
	Insecure bool   `mapstructure:"insecure"`
	CAFile   string `mapstructure:"cafile"`
}