kafka

Documentation

Index

• type Client
• type Config
• type SASLConfig
• type TLSConfig

Types

type Client

type Client interface {
	Open() error
	Close() error
	ListTopics(ctx context.Context) ([]string, error)
	ListConsumerGroups(ctx context.Context) ([]string, error)
	ListConsumeTopics(ctx context.Context, consumerGroup string) ([]string, error)
	ListTopicsPartitionCounts(ctx context.Context, topics []string) (map[string]int, error)
}

type Config

type Config struct {
	Addresses   []string       `mapstructure:"brokerAddresses"`
	Version     string         `mapstructure:"version"`
	DialTimeout *time.Duration `mapstructure:""`
	KeepAlive   *time.Duration `mapstructure:""`

	SASL *SASLConfig `mapstructure:"sasl"`
	TLS  *TLSConfig  `mapstructure:"tls"`
}

type SASLConfig

type SASLConfig struct {
	Enabled  bool   `mapstructure:"enabled"`
	Username string `mapstructure:"username"`
	Password string `mapstructure:"password"`
}

type TLSConfig

type TLSConfig struct {
	Enabled            bool `mapstructure:"enabled"`
	InsecureSkipVerify bool `mapstructure:"insecureSkipVerify"`
}