consumer

Documentation

Index

• type Config
• type Consumer
  • func New(config Config, topics []string, handler Handler) (*Consumer, error)
  • func (c *Consumer) HealthCheck() error
  • func (c *Consumer) Poll(ctx context.Context)
  • func (c *Consumer) Run(ctx context.Context, wg *sync.WaitGroup)
• type Handler
• type SSLConfig

Types

type Config

type Config struct {
	PollTimeoutMs    int
	Name             string
	BootstrapServers string
	GroupID          string
	SessionTimeoutMs string
	AutoOffsetReset  string
	SSL              SSLConfig
}

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func New

func New(config Config, topics []string, handler Handler) (*Consumer, error)

func (*Consumer) HealthCheck

func (c *Consumer) HealthCheck() error

func (*Consumer) Poll

func (c *Consumer) Poll(ctx context.Context)

func (*Consumer) Run

func (c *Consumer) Run(ctx context.Context, wg *sync.WaitGroup)

type Handler

type Handler interface {
	// If 'Handle' returns an error, a message will not be committed.
	Handle(ctx context.Context, key, value []byte, timestamp time.Time) error
}

type SSLConfig

type SSLConfig struct {
	Enabled             bool
	KeyLocation         string
	CertificateLocation string
	CALocation          string
}