kafka

package

v0.0.0-...-2b644c5 Latest Latest Go to latest Published: Apr 1, 2021 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func ParseVersion(config *sarama.Config, version string) error

type Producer struct {
	SyncProducer sarama.SyncProducer
	Topic        string
}

func (p Producer) Publish(topicPostfix, k string, vv []byte) (*PublishResponse, error)

type ProducerConfig struct {
	Topic   string
	Version string
	Brokers []string

	TlsConfig
}

func (c ProducerConfig) NewSyncProducer() (*Producer, error)

type PublishResponse struct {
	Partition int32  `json:"partition"`
	Offset    int64  `json:"offset"`
	Topic     string `json:"topic"`
}

type TlsConfig struct {
	CaFile, CertFile, KeyFile string
	InsecureSkipVerify        bool
}

func (tc TlsConfig) CreateTlsConfig() *tls.Config