kafka

Documentation

Index

• func NewKafkaFilter(c *config.Config) (pipeline.Filter, error)
• type Kafka
  • func (filter *Kafka) Filter(ctx *fasthttp.RequestCtx)
  • func (filter *Kafka) Name() string

Functions

func NewKafkaFilter

func NewKafkaFilter(c *config.Config) (pipeline.Filter, error)

Types

type Kafka

type Kafka struct {
	Topic            string   `config:"topic"`
	BatchSize        int      `config:"batch_size"`
	BatchTimeoutInMs int      `config:"batch_timeout_in_ms"`
	RequiredAcks     int      `config:"required_acks"`
	Brokers          []string `config:"brokers"`
	// contains filtered or unexported fields
}

func (*Kafka) Filter

func (filter *Kafka) Filter(ctx *fasthttp.RequestCtx)

func (*Kafka) Name

func (filter *Kafka) Name() string