kafka

Documentation

Index

• type Config
  • func NewConfig(rootCaFile string) (*Config, error)
• type Message
• type Reader
  • func NewReader(address string) (*Reader, error)
  • func (r *Reader) Read() chan *Message
• type SyncWriter
  • func NewSyncWriter(rootCaFile, address string, partitionId int) (*SyncWriter, error)
  • func (s *SyncWriter) Close() error
  • func (s *SyncWriter) SimpleWrite(input []byte) error
  • func (s *SyncWriter) Start() error

Types

type Config

type Config struct {
	Config *sarama.Config
}

func NewConfig

func NewConfig(rootCaFile string) (*Config, error)

type Message

type Message struct {
	Key       []byte
	Value     []byte
	Offset    int64
	TimeStamp time.Time
}

type Reader

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

func NewReader

func NewReader(address string) (*Reader, error)

func (*Reader) Read

func (r *Reader) Read() chan *Message

type SyncWriter

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

func NewSyncWriter

func NewSyncWriter(rootCaFile, address string, partitionId int) (*SyncWriter, error)

func (*SyncWriter) Close

func (s *SyncWriter) Close() error

func (*SyncWriter) SimpleWrite

func (s *SyncWriter) SimpleWrite(input []byte) error

func (*SyncWriter) Start

func (s *SyncWriter) Start() error