kafka

Documentation

Index

• type KafkaConsumer
  • func NewKafkaConsumer(topic, group string) *KafkaConsumer
• type KafkaConsumerAdapter
  • func NewKafkaConsumerAdapter(topic, group string) *KafkaConsumerAdapter
  • func (kca *KafkaConsumerAdapter) Register(handler *domain.PrimaryAdapterHandler) error
  • func (kca KafkaConsumerAdapter) Serve(ctx context.Context, shutdownWg, readyWg *sync.WaitGroup) error

Types

type KafkaConsumer

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

func NewKafkaConsumer

func NewKafkaConsumer(topic, group string) *KafkaConsumer

type KafkaConsumerAdapter

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

func NewKafkaConsumerAdapter

func NewKafkaConsumerAdapter(topic, group string) *KafkaConsumerAdapter

func (*KafkaConsumerAdapter) Register

func (kca *KafkaConsumerAdapter) Register(handler *domain.PrimaryAdapterHandler) error

func (KafkaConsumerAdapter) Serve

func (kca KafkaConsumerAdapter) Serve(ctx context.Context, shutdownWg, readyWg *sync.WaitGroup) error