client

Aug 4, 2023

Changes in this version

type CfgTLS

+ InsecureSkipVerify bool

Jun 17, 2021

Changes in this version

type Client

+ func (c *Client) GroupTransactSession() *kgo.GroupTransactSession

May 19, 2021

Changes in this version

+ func Wizard(noHelp bool)

type CfgSASL

+ AccessKey string

+ SecretKey string

Sep 12, 2020

Changes in this version

+ func Strnorm(s string) string

Aug 24, 2020

Changes in this version

type CfgTLS

+ CipherSuites []string

+ CurvePreferences []string

+ MinVersion string

type Client

+ func (c *Client) RemakeWithOpts(opts ...kgo.Opt)

Jun 30, 2020

Changes in this version

+ type Cfg struct

+ SASL CfgSASL

+ SeedBrokers []string

+ TLS *CfgTLS

+ TimeoutMillis int32

+ type CfgSASL struct

+ IsToken bool

+ Method string

+ Pass string

+ User string

+ Zid string

+ type CfgTLS struct

+ CACert string

+ ClientCertPath string

+ ClientKeyPath string

+ ServerName string

+ type Client struct

+ func New(root *cobra.Command) *Client

+ func (c *Client) AddOpt(opt kgo.Opt)

+ func (c *Client) AsJSON() bool

+ func (c *Client) Client() *kgo.Client

+ func (c *Client) DefaultCfgPath() string

+ func (c *Client) DiskCfg() Cfg

+ func (c *Client) TimeoutMillis() int32

+ type Requestor interface

+ Request func(context.Context, kmsg.Request) (kmsg.Response, error)