kafka

Apr 18, 2022

Changes in this version

+ var DefaultConfig = KafkaOptions

+ func CreateKafkaTransporter(options KafkaOptions) transit.Transport

+ type KafkaOptions struct

+ Addr string

+ Logger *log.Entry

+ Name string

+ Serializer serializer.Serializer

+ Url string

+ type KafkaTransporter struct

+ func (t *KafkaTransporter) Connect() chan error

+ func (t *KafkaTransporter) Disconnect() chan error

+ func (t *KafkaTransporter) Publish(command, nodeID string, message moleculer.Payload)

+ func (t *KafkaTransporter) SetNodeID(nodeID string)

+ func (t *KafkaTransporter) SetPrefix(prefix string)

+ func (t *KafkaTransporter) SetSerializer(serializer serializer.Serializer)

+ func (t *KafkaTransporter) Subscribe(command, nodeID string, handler transit.TransportHandler)