package
0.1.1
Repository: https://github.com/cashwagon/qrpc.git
Documentation: pkg.go.dev

# 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.