wkafka

Documentation

Index

• type WrapperKafka
  • func NewWrapperKafka() (*WrapperKafka, error)
  • func NewWrapperKafkaConsumer(server, groupId, autoOffsetReset string) (*WrapperKafka, error)
  • func NewWrapperKafkaProducer() (*WrapperKafka, error)
  • func (wrapperKafka *WrapperKafka) Close()
  • func (wrapperKafka *WrapperKafka) Consumer() (*kafka.Consumer, error)
  • func (wrapperKafka *WrapperKafka) Producer() (*kafka.Producer, error)

Types

type WrapperKafka

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

Wrapper type

func NewWrapperKafka

func NewWrapperKafka() (*WrapperKafka, error)

Creates a new kafka wrapper with both consumer and producer

func NewWrapperKafkaConsumer

func NewWrapperKafkaConsumer(server, groupId,
	autoOffsetReset string) (*WrapperKafka, error)

Creates a new kafka wrapper with consumer

func NewWrapperKafkaProducer

func NewWrapperKafkaProducer() (*WrapperKafka, error)

Creates a new kafka wrapper with producer

func (*WrapperKafka) Close

func (wrapperKafka *WrapperKafka) Close()

Closes kafka connections

func (*WrapperKafka) Consumer

func (wrapperKafka *WrapperKafka) Consumer() (*kafka.Consumer, error)

Returns kafka consumer

func (*WrapperKafka) Producer

func (wrapperKafka *WrapperKafka) Producer() (*kafka.Producer, error)

Returns kafka producer