kafka

Documentation

Index

• type Ingester
  • func NewIngester(addr string, groupID string, topic string) (*Ingester, error)
  • func (i *Ingester) Ingest(ctx context.Context) (chan model.RatingEvent, error)

Types

type Ingester

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

Ingester defines a Kafka ingester.

func NewIngester

func NewIngester(addr string, groupID string, topic string) (*Ingester, error)

NewIngester creates a new Kafka ingester.

func (*Ingester) Ingest

func (i *Ingester) Ingest(ctx context.Context) (chan model.RatingEvent, error)

Ingest starts ingestion from Kafka and returns a channel representing the data consumed from the topic.