Versions in this module Expand all Collapse all v1 v1.0.2 Jul 7, 2024 v1.0.1 Jul 7, 2024 Changes in this version + func NewSource(opts ...source.Option) source.Source + func WithAddress(addrs []string) source.Option + func WithClientConfig(cc constant.ClientConfig) source.Option + func WithDataId(id string) source.Option + func WithGroup(g string) source.Option
Go to main page