Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2021 Changes in this version + func NewConn(ctx context.Context) (*kafka.Conn, error) + func NewConnWithOptions(ctx context.Context, o *Options) (conn *kafka.Conn, err error) + type Options struct + Address string + ConnType string + Network string + Partition int + Topic string + func NewOptions() (*Options, error) + func NewOptionsWithPath(path string) (opts *Options, err error)
Go to main page