Categorygithub.com/cashwagon/qrpcpkgdriverskafka
package
0.1.1
Repository: https://github.com/cashwagon/qrpc.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
2
Files
151 SLOC

# Functions

NewConsumer allocates new Consumer object.
NewProducer allocates new Producer object.

# Structs

Consumer represents the wrapper on kafka.Reader.
Producer represents the wrapper on kafka.Writer.

# Interfaces

Reader represents abstract reader interface to wrap kafka.Reader.
Writer represents abstract writer interface to wrap kafka.Writer.