Versions in this module Expand all Collapse all v0 v0.0.2 Dec 22, 2023 v0.0.1 Dec 19, 2023 Changes in this version + func InitTopic(bootstrapUrl string, topics ...string) (err error) + type Consumer struct + func NewConsumer(broker string, groupid string, topic string, debug bool, ...) (consumer *Consumer, err error) + func (this *Consumer) Restart() + func (this *Consumer) Stop() + type Interface interface + Close func() + Consume func(topic string, listener func(delivery []byte) error) (err error) + EnsureTopic func(bootstrapUrl string, topic string, config map[string]string) (err error) + Publish func(topic string, key string, payload []byte) error + func Init(broker string, group string, debug bool) (Interface, error) + type Kafka struct + func (this *Kafka) Close() + func (this *Kafka) Consume(topic string, listener func(delivery []byte) error) (err error) + func (this *Kafka) EnsureTopic(bootstrapUrl string, topic string, config map[string]string) (err error) + func (this *Kafka) Publish(topic string, key string, payload []byte) error + type Publisher struct + func NewPublisher(broker string, topic string, debug bool) (*Publisher, error) + func (this *Publisher) Publish(topic string, key string, payload []byte) (err error)