package
0.0.0-20230424045628-a36dcc1d90e4
Repository: https://github.com/weedge/lib.git
Documentation: pkg.go.dev

# Functions

user just defined open consumer group option.
kafka brokers ip:port,ip:port.
consumer groupId.
initial offset to consumer (oldest, newest).
consumer group partition assignment strategy (range, roundrobin, sticky).
subscribe topics "test1,test2".
kafka version.

# Structs

Consumer represents a Sarama consumer group consumer.
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author