kafkaingest

Documentation

Index

• type Collector
  • func (s Collector) Receive(ev event.Event) error
• type Schema
  • func NewSchema(schemaRegistry schemaregistry.Client, topic string) (Schema, int, int, error)

Types

type Collector

type Collector struct {
	Producer *kafka.Producer
	Topic    string
	Schema   Schema
}

Collector is a receiver of events that handles sending those events to a downstream Kafka broker.

func (Collector) Receive

func (s Collector) Receive(ev event.Event) error

type Schema

type Schema interface {
	SerializeKey(topic string, ev event.Event) ([]byte, error)
	SerializeValue(topic string, ev event.Event) ([]byte, error)
}

Schema serializes events.

func NewSchema

func NewSchema(schemaRegistry schemaregistry.Client, topic string) (Schema, int, int, error)

NewSchema initializes a new schema in the registry.