kafka

package
v4.2.722+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 4, 2020 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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"`
}

Directories

Path Synopsis
Package mock_kafka is a generated GoMock package.
Package mock_kafka is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL