kafka

Documentation

Index

• type Component
  • func New(name string, p async.ProcessorFunc, clientID string, brokers []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 string, brokers []string, topics []string, ct string) (*Component, error)

New returns a new component.

func (*Component) Run

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

Run starts the async processing.

func (*Component) Shutdown

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

Shutdown the component.