kafka

Documentation

Index

• type Component
  • func New(name string, p async.ProcessorFunc, clientID, ct string, ...) (*Component, error)
  • func (c *Component) Run(ctx context.Context) error
  • func (c *Component) Shutdown(ctx context.Context) error

Types

type Component

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

Component implementation of a kafka consumer.

func New

func New(name string, p async.ProcessorFunc, clientID, ct string, brokers, topics []string) (*Component, error)

New returns a new kafka consumer component.

func (*Component) Run

func (c *Component) Run(ctx context.Context) error

Run starts the kafka consumer processing messages.

func (*Component) Shutdown

func (c *Component) Shutdown(ctx context.Context) error

Shutdown gracefully the component by closing the kafka consumer.