kafka

package

v0.0.0-...-059ff10 Latest Latest Go to latest Published: Nov 21, 2020 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Kafka type to hold reader and writer instances

func GenerateFromConfig(ctx context.Context, configPath string) *Kafka

GenerateFromConfig generates readers and writes from a given config file

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

Reader is wrapper around kafka.Reader

func GenerateReader(ctx context.Context, brokers []string, topic string, groupID string) *Reader

GenerateReader creates a reader kafka instance to respond to incoming requests

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

Writer is a wrapper around kafka.Writer

func GenerateWriter(ctx context.Context, brokers []string, topic string) *Writer

GenerateWriter creates a writer kafka instance to make outgoing responses