Categorygithub.com/onexstack/onexpkgstreamsconnectorkafka
package
0.2.0-alpha.14
Repository: https://github.com/onexstack/onex.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
8
Dependents
1
Files
102 SLOC

# Functions

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

# Structs

KafkaSink represents an Apache Kafka sink connector.
KafkaSource represents an Apache Kafka source connector.