kafka

Documentation

Index

• func CloseProducer(ctx context.Context, pi interface{}) error
• func Init()
• func NewProducer(destConfigJSON interface{}, o Opts) (*producerImpl, error)
• func NewProducerForAzureEventHubs(destinationConfig interface{}, o Opts) (*producerImpl, error)
• func NewProducerForConfluentCloud(destinationConfig interface{}, o Opts) (*producerImpl, error)
• func Produce(jsonData json.RawMessage, pi interface{}, destConfig interface{}) (int, string, string)
• type Opts

Functions

func CloseProducer

func CloseProducer(ctx context.Context, pi interface{}) error

CloseProducer closes a given producer

func Init

func Init()

func NewProducer

func NewProducer(destConfigJSON interface{}, o Opts) (*producerImpl, error)

NewProducer creates a producer based on destination config

func NewProducerForAzureEventHubs

func NewProducerForAzureEventHubs(destinationConfig interface{}, o Opts) (*producerImpl, error)

NewProducerForAzureEventHubs creates a producer for Azure event hub based on destination config

func NewProducerForConfluentCloud

func NewProducerForConfluentCloud(destinationConfig interface{}, o Opts) (*producerImpl, error)

NewProducerForConfluentCloud creates a producer for Confluent cloud based on destination config

func Produce

func Produce(jsonData json.RawMessage, pi interface{}, destConfig interface{}) (int, string, string)

Produce creates a producer and send data to Kafka.

Types

type Opts

type Opts struct {
	Timeout time.Duration
}