sink

Documentation

Index

• type Connector
• type KafkaConnect
  • func NewKafkaConnect(config KafkaConnectConfig) (KafkaConnect, error)
  • func (k *KafkaConnect) CreateConnector(ctx context.Context, connector Connector) error
• type KafkaConnectConfig

Types

type Connector

type Connector struct {
	Name   string            `json:"name"`
	Config map[string]string `json:"config"`
}

type KafkaConnect

type KafkaConnect struct {
	// contains filtered or unexported fields
}

func NewKafkaConnect

func NewKafkaConnect(config KafkaConnectConfig) (KafkaConnect, error)

func (*KafkaConnect) CreateConnector

func (k *KafkaConnect) CreateConnector(ctx context.Context, connector Connector) error

type KafkaConnectConfig

type KafkaConnectConfig struct {
	URL        string
	HttpClient *http.Client
	Logger     *slog.Logger
}