Versions in this module Expand all Collapse all v0 v0.0.1 Apr 16, 2024 Changes in this version + type KafkaSink struct + func NewKafkaSink(ctx context.Context, config kafka.WriterConfig) (*KafkaSink, error) + func (ks *KafkaSink) In() chan<- any + type KafkaSource struct + 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
Go to main page