kafka

Documentation

Overview

Package kafka implements the Apache Kafka connector.

Index

• type KafkaSink
  • func NewKafkaSink(ctx context.Context, config kafka.WriterConfig) (*KafkaSink, error)
  • func (ks *KafkaSink) In() chan<- any
• type KafkaSource
  • func NewKafkaSource(ctx context.Context, config kafka.ReaderConfig) (*KafkaSource, error)
  • func (ks *KafkaSource) Out() <-chan any
  • func (ks *KafkaSource) Via(_flow streams.Flow) streams.Flow

Types

type KafkaSink

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

KafkaSink represents an Apache Kafka sink connector.

func NewKafkaSink

func NewKafkaSink(ctx context.Context, config kafka.WriterConfig) (*KafkaSink, error)

NewKafkaSink returns a new KafkaSink instance.

func (*KafkaSink) In

func (ks *KafkaSink) In() chan<- any

In returns an input channel for receiving data.

type KafkaSource

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

KafkaSource represents an Apache Kafka source connector.

func NewKafkaSource

func NewKafkaSource(ctx context.Context, config kafka.ReaderConfig) (*KafkaSource, error)

NewKafkaSource returns a new KafkaSource instance.

func (*KafkaSource) Out

func (ks *KafkaSource) Out() <-chan any

Out returns an output channel for sending data.

func (*KafkaSource) Via

func (ks *KafkaSource) Via(_flow streams.Flow) streams.Flow

Via streams data through the given flow.