kafkaadmin

package

Go to main page

Versions in this module

v4

v4.2.1

Feb 9, 2023

v4.2.0

Aug 12, 2022

v4.1.0

Aug 3, 2022

Changes in this version

+ type BrokerState struct

+ FullData map[string]string

+ Host string

+ InterBrokerProtocolVersion string

+ LogMessageFormat string

+ Port int

+ Rack string

+ type BrokerStates map[int]BrokerState

+ func NewBrokerStates() BrokerStates

type Client

+ DefaultTimeoutMs int

+ func (c Client) DescribeBrokers(ctx context.Context, fullData bool) (BrokerStates, error)

+ func (c Client) GetConfigs(ctx context.Context, kind string, names []string) (ResourceConfigs, error)

+ func (c Client) ListBrokers(ctx context.Context) ([]int, error)

+ func (c Client) UnderReplicatedTopics(ctx context.Context) (TopicStates, error)

type Config

+ DefaultTimeoutMs int

type KafkaAdmin

+ DescribeBrokers func(context.Context, bool) (BrokerStates, error)

+ GetConfigs func(context.Context, string, []string) (ResourceConfigs, error)

+ ListBrokers func(context.Context) ([]int, error)

+ UnderReplicatedTopics func(context.Context) (TopicStates, error)

type TopicState

+ func (t TopicState) Brokers() []int

type TopicStates

+ func (t TopicStates) List() []string

+ func (ts TopicStates) UnderReplicated() TopicStates

v4.0.0

May 17, 2022

Changes in this version

+ var ErrNoData = fmt.Errorf("no data returned")

+ var SASLMechanismSet = map[string]struct

+ var SecurityProtocolSet = map[string]struct

+ func NewConsumer(cfg Config) (*kafka.Consumer, error)

+ type BrokerThrottleConfig struct

+ InboundLimitBytes int

+ OutboundLimitBytes int

+ type Client struct

+ func NewClientWithFactory(cfg Config, factory FactoryFunc) (*Client, error)

+ func (c Client) Close()

+ func (c Client) CreateTopic(ctx context.Context, cfg CreateTopicConfig) error

+ func (c Client) DeleteTopic(ctx context.Context, name string) error

+ func (c Client) DescribeTopics(ctx context.Context, topics []string) (TopicStates, error)

+ func (c Client) GetDynamicConfigs(ctx context.Context, kind string, names []string) (ResourceConfigs, error)

+ func (c Client) RemoveThrottle(ctx context.Context, cfg RemoveThrottleConfig) error

+ func (c Client) SetThrottle(ctx context.Context, cfg SetThrottleConfig) error

+ type Config struct

+ BootstrapServers string

+ GroupId string

+ SASLMechanism string

+ SASLPassword string

+ SASLUsername string

+ SSLCALocation string

+ SecurityProtocol string

+ type CreateTopicConfig struct

+ Config map[string]string

+ Name string

+ Partitions int

+ ReplicaAssignment ReplicaAssignment

+ ReplicationFactor int

+ type ErrRemoveThrottle struct

+ Message string

+ func (e ErrRemoveThrottle) Error() string

+ type ErrSetThrottle struct

+ Message string

+ func (e ErrSetThrottle) Error() string

+ type ErrorFetchingMetadata struct

+ Message string

+ func (e ErrorFetchingMetadata) Error() string

+ type FactoryFunc func(conf *kafka.ConfigMap) (*kafka.AdminClient, error)

+ type KafkaAdmin interface

+ Close func()

+ CreateTopic func(context.Context, CreateTopicConfig) error

+ DeleteTopic func(context.Context, string) error

+ DescribeTopics func(context.Context, []string) (TopicStates, error)

+ GetDynamicConfigs func(context.Context, string, []string) (ResourceConfigs, error)

+ RemoveThrottle func(context.Context, RemoveThrottleConfig) error

+ SetThrottle func(context.Context, SetThrottleConfig) error

+ func NewClient(cfg Config) (KafkaAdmin, error)

+ type PartitionState struct

+ ID int32

+ ISR []int32

+ Leader int32

+ Replicas []int32

+ type RemoveThrottleConfig struct

+ Brokers []int

+ Topics []string

+ type ReplicaAssignment [][]int32

+ type ResourceConfigs map[string]map[string]string

+ func (rc ResourceConfigs) AddConfig(name, key, value string) error

+ func (rc ResourceConfigs) AddConfigEntry(name string, config kafka.ConfigEntryResult) error

+ type SetThrottleConfig struct

+ Brokers map[int]BrokerThrottleConfig

+ Topics []string

+ type TopicState struct

+ Name string

+ PartitionStates map[int]PartitionState

+ Partitions int32

+ ReplicationFactor int32

+ func NewTopicState(name string) TopicState

+ type TopicStates map[string]TopicState

+ func NewTopicStates() TopicStates

+ func TopicStatesFromMetadata(md *kafka.Metadata) (TopicStates, error)

Other modules containing this package

github.com/DataDog/kafka-kit/v3

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