kafconn

Documentation

Index

• type Kafka
  • func NewKafka(ctx context.Context, tls TLSSetup) (*Kafka, error)
  • func (k *Kafka) CheckPartitions() error
  • func (k *Kafka) NewReader(config kafka.ReaderConfig) *kafka.Reader
  • func (k *Kafka) NewWriter(topic string) (*kafka.Writer, error)
• type TLSSetup

Types

type Kafka

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

func NewKafka

func NewKafka(ctx context.Context, tls TLSSetup) (*Kafka, error)

func (*Kafka) CheckPartitions

func (k *Kafka) CheckPartitions() error

func (*Kafka) NewReader

func (k *Kafka) NewReader(config kafka.ReaderConfig) *kafka.Reader

func (*Kafka) NewWriter

func (k *Kafka) NewWriter(topic string) (*kafka.Writer, error)

type TLSSetup

type TLSSetup struct {
	CA   string
	Key  string
	Cert string
}