Categorygithub.com/wangjuelong/go-streamskafka
package
0.6.7
Repository: https://github.com/wangjuelong/go-streams.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
9
Dependents
0
Files
163 SLOC

# Functions

NewKafkaSink returns a new KafkaSink instance.
NewKafkaSource returns a new KafkaSource instance.

# Structs

GroupHandler represents a Sarama consumer group handler.
KafkaSink connector.
KafkaSource connector.