reader

Documentation

Index

• type Config
• type KafkaReader
  • func New(consumerName string) (*KafkaReader, error)
  • func (c *KafkaReader) Shutdown(timeout int)
  • func (c *KafkaReader) Start() error

Types

type Config

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

type KafkaReader

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

func New

func New(consumerName string) (*KafkaReader, error)

func (*KafkaReader) Shutdown

func (c *KafkaReader) Shutdown(timeout int)

func (*KafkaReader) Start

func (c *KafkaReader) Start() error