Categorygithub.com/luopengift/pkgkafka2
package
0.0.2
Repository: https://github.com/luopengift/pkg.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
5
Dependents
0
Files
77 SLOC

# Functions

NewConsumer kafka input.

# Constants

VERSION version.

# Structs

Consumer xx 一些使用说明: sarame.OffsetNewest int64 = -1 sarame.OffsetOldest int64 = -2.