Versions in this module Expand all Collapse all v1 v1.0.6 Aug 29, 2023 v1.0.5 Aug 14, 2023 Changes in this version + func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config, error) + type TLSKafkaUploader struct + 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