go_kafka_integrator

Documentation

Index

• Variables
• func NewEventConsumer(options ConsumerOptions) (base.EventConsumer, error)
• func NewEventProducer(options ProducerOptions) (base.EventProducer, error)
• type ConsumerOptions
• type ProducerOptions

Variables

var EventConsumerType = eventConsumerTypes{
	JSON: "json",
	AVRO: "avro",
}

var EventProducerType = eventProducerTypes{
	JSON: "json",
	AVRO: "avro",
}

Functions

func NewEventConsumer

func NewEventConsumer(options ConsumerOptions) (base.EventConsumer, error)

func NewEventProducer

func NewEventProducer(options ProducerOptions) (base.EventProducer, error)

Types

type ConsumerOptions

type ConsumerOptions struct {
	BootstrapServers       string
	ConsumerGroupId        string
	ClusterUsername        string
	ClusterPassword        string
	EventConsumerType      string
	Logger                 logger.Logger
	SchemaRegistryURL      string
	SchemaRegistryUsername string
	SchemaRegistryPassword string
	StatsDHost             string
	StatsDPort             string
	StatsDPrefix           string
}

type ProducerOptions

type ProducerOptions struct {
	BootstrapServers       string
	ClusterUsername        string
	ClusterPassword        string
	EventProducerType      string
	Logger                 logger.Logger
	SchemaRegistryURL      string
	SchemaRegistryUsername string
	SchemaRegistryPassword string
	StatsDHost             string
	StatsDPort             string
	StatsDPrefix           string
}