kaf

Mar 26, 2019

Changes in this version

type Cluster

+ SchemaRegistryURL string

+ TLS *TLS

+ type TLS struct

+ Cafile string

+ Insecure bool

Oct 2, 2018

Changes in this version

type Config

+ func (c *Config) SetCurrentCluster(name string) error

Sep 30, 2018

Changes in this version

+ var ErrInsufficientData = errors.New("kafka: insufficient data to decode packet, more bytes expected")

+ func ParseConfluentCloudConfig(path string) (username, password, broker string, err error)

+ func TryFindCcloudConfigFile() (string, error)

+ type Cluster struct

+ Brokers []string

+ Name string

+ SASL *SASL

+ SecurityProtocol string

+ type Config struct

+ Clusters []*Cluster

+ CurrentCluster string

+ func ReadConfig() (c Config, err error)

+ func (c *Config) ActiveCluster() *Cluster

+ func (c *Config) Write() error

+ type PacketDecoder interface

+ func NewDecoder(raw []byte) PacketDecoder

+ type SASL struct

+ Mechanism string

+ Password string

+ Username string

+ type SubscriptionInfo struct

+ PrevTasks []TaskID

+ ProcessID string

+ StandbyTasks []TaskID

+ UUID []byte

+ UserEndpoint string

+ Version int32

+ func (s *SubscriptionInfo) Decode(pd PacketDecoder) (err error)

+ type TaskID struct

+ Partition int32

+ TopicGroupID int32