connection

Documentation

Index

• Constants
• func NewDialer(conf *Settings) (*kafka.Dialer, error)
• type Settings
  • func ParseSettings(c cfg.Config, name string) *Settings

Constants

const (
	// DefaultDialerTimeout is how long to wait for TCP connection to be established with bootstrap.
	DefaultDialerTimeout = 10 * time.Second

	// DefaultKeepAlive is how long an unused connection should be kept open in the hope of re-use.
	DefaultKeepAlive = 10 * time.Minute
)

Functions

func NewDialer

func NewDialer(conf *Settings) (*kafka.Dialer, error)

NewDialer is a dialer factory.

Types

type Settings

type Settings struct {
	// Connection.
	Bootstrap          []string `cfg:"bootstrap" validate:"required"`
	InsecureSkipVerify bool     `cfg:"insecure_skip_verify"`

	// Credentials.
	Username string `cfg:"username"`
	Password string `cfg:"password"`
}

func ParseSettings

func ParseSettings(c cfg.Config, name string) *Settings