Categorygithub.com/Golang-Tools/kafkahelperconsumerproxy
package
0.0.1
Repository: https://github.com/golang-tools/kafkahelper.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
7
Dependents
0
Files
203 SLOC

# Functions

New 创建一个新的数据库客户端代理.
WithAutoOffsetReset 设置监听时自动重置offset的策略@params strategy string 自动重置offset的策略,可选的有earliest,latest,err3种.
WithComsumerSetting 设置监听时的其他设置,具体设置可以看<https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md>@params key string 设置项@params value any 设置项的值.
WithGroupID 设置监听时使用的groupid@params groupID string 指定的groupid.
WithIsolationLevel 设置监听时读取消息的策略@params strategy string 读取消息的策略,可选的有read_uncommitted, read_committed2种.
WithParallelCallback 设置callback并行执行.
WithGroupID 设置监听时使用uuid4作为groupid@params namespace ...string 指定的groupid的命名空间,命名空间会按顺序使用`-`连接,然后作为前缀与uuid使用`__`相连.

# Variables

Default 默认的kafka Consumer代理对象.
No description provided by the author
ErrProxyAllreadySettedCallback 代理已经设置过回调函数.
ErrProxyAllreadySettedClient 代理已经设置过kafka消费者客户端.
No description provided by the author

# Structs

ConsumerProxy redis客户端的代理.
Options 设置代理对象初始化方法的可选参数.

# Type aliases

Callback redis操作的回调函数.
No description provided by the author
No description provided by the author