kafka

Aug 4, 2025

Changes in this version

+ type Session struct

+ AdminClient *kadm.Client

+ Client *kgo.Client

+ ConnectClient Connect

+ Ctx KafkaContext

+ Options []kgo.Opt

+ SchemaRegistryClient *sr.Client

+ func NewSession(ctx KafkaContext) (*Session, error)

+ func (s *Session) GetAdminClient() (*kadm.Client, error)

+ func (s *Session) GetClient(opts ...kgo.Opt) (*kgo.Client, error)

+ func (s *Session) GetConnectClient() (Connect, error)

+ func (s *Session) GetSchemaRegistryClient() (*sr.Client, error)

+ func (s *Session) SetKafkaContext(ctx KafkaContext) error

May 2, 2025

Changes in this version

+ var KafkaAdminClient *kadm.Client

+ var KafkaClient *kgo.Client

+ var KafkaSchemaRegistryClient *sr.Client

+ func GetKafkaAdminClient() (*kadm.Client, error)

+ func GetKafkaClient(opts ...kgo.Opt) (*kgo.Client, error)

+ func GetKafkaSchemaRegistryClient() (*sr.Client, error)

+ func NewCurrentKafkaContext(kc KafkaContext) error

+ func ResetCurrentKafkaContext()

+ type Connect interface

+ CreateConnector func(ctx context.Context, name string, config map[string]string) (*ConnectorInfo, error)

+ DeleteConnector func(ctx context.Context, name string) error

+ GetConnector func(ctx context.Context, name string) (*ConnectorInfo, error)

+ GetConnectorConfig func(ctx context.Context, name string) (map[string]string, error)

+ GetConnectorStatus func(ctx context.Context, name string) (*ConnectorInfo, error)

+ GetConnectorTasks func(ctx context.Context, name string) ([]TaskInfo, error)

+ GetInfo func(ctx context.Context) (map[string]interface{}, error)

+ ListConnectors func(ctx context.Context) ([]string, error)

+ ListPlugins func(ctx context.Context) ([]PluginInfo, error)

+ PauseConnector func(ctx context.Context, name string) error

+ RestartConnector func(ctx context.Context, name string) error

+ ResumeConnector func(ctx context.Context, name string) error

+ UpdateConnector func(ctx context.Context, name string, config map[string]string) (*ConnectorInfo, error)

+ ValidateConfig func(ctx context.Context, pluginClass string, config map[string]string) (map[string]interface{}, error)

+ var KafkaConnectClient Connect

+ func GetKafkaConnectClient() (Connect, error)

+ func NewConnect(kc *KafkaContext) (Connect, error)

+ type ConnectorInfo struct

+ Config map[string]string

+ Name string

+ State ConnectorState

+ Tasks []TaskInfo

+ Type string

+ type ConnectorState string

+ const ConnectorStateFailed

+ const ConnectorStatePaused

+ const ConnectorStateRunning

+ const ConnectorStateStopped

+ type KafkaContext struct

+ AuthMechanism string

+ AuthPass string

+ AuthType string

+ AuthUser string

+ BootstrapServers string

+ CaFile string

+ ClientCertFile string

+ ClientKeyFile string

+ ConnectAuthPass string

+ ConnectAuthUser string

+ ConnectURL string

+ SchemaRegistryAuthPass string

+ SchemaRegistryAuthUser string

+ SchemaRegistryBearerToken string

+ SchemaRegistryURL string

+ UseTLS bool

+ var CurrentKafkaContext KafkaContext

+ func (kc *KafkaContext) SetKafkaContext() error

+ type PluginInfo struct

+ Class string

+ Type string

+ Version string

+ type SASLConfig struct

+ Mechanism string

+ Password string

+ Username string

+ type TLSConfig struct

+ CaFile string

+ ClientCertFile string

+ ClientKeyFile string

+ Enabled bool

+ type TaskInfo struct

+ ID int

+ State ConnectorState

+ Trace string

+ WorkerID string