kafka

package

v0.0.0-...-4d250b4 Latest Latest Go to latest Published: Feb 19, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func SpawnConsumer(kc *KafkaConsumer, redis *redis.Redis, quit <-chan os.Signal)

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

func NewConsumer(host, port, topic, groupID string) (*KafkaConsumer, error)

func (kc *KafkaConsumer) Close()

type KafkaProducer struct {
	Topic *string
	// contains filtered or unexported fields
}

func NewProducer(host, port, topic string) (*KafkaProducer, error)

func (kp *KafkaProducer) Close()

func (kp *KafkaProducer) Produce(event []byte) error

type NumberEvent struct {
	EventType string `json:"type"`
	Number    int    `json:"number"`
}