kafka

Documentation

Index

• func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config, error)
• type TLSKafkaUploader
  • func NewTLSKafkaUploader(kafkaUrl string, certFile string, keyFile string, caFile string) (ku *TLSKafkaUploader, err error)
  • func (ku *TLSKafkaUploader) Close()
  • func (ku *TLSKafkaUploader) SendMessage(topic string, key string, value string) error

Functions

func NewTLSConfig

func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config, error)

Types

type TLSKafkaUploader

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

func NewTLSKafkaUploader

func NewTLSKafkaUploader(kafkaUrl string, certFile string, keyFile string, caFile string) (ku *TLSKafkaUploader, err error)

func (*TLSKafkaUploader) Close

func (ku *TLSKafkaUploader) Close()

func (*TLSKafkaUploader) SendMessage

func (ku *TLSKafkaUploader) SendMessage(topic string, key string, value string) error