kafka

Documentation

Overview

Package kafka implements a kafka client.

Index

• type Client
  • func New(conf *configs.KafkaConfig) Client
• type Consumer
• type Message

Types

type Client

type Client interface {
	SendMessage(ctx context.Context, msg *Message) (string, error)
	NewConsumer(ctx context.Context, topic, group string,
		handler func(context.Context, *Message) error) (Consumer, error)
	CreateTopic(ctx context.Context, topic string, numPartitions, replicationFactor int) error
	Close() error
}

Client kafka client interface

func New

func New(conf *configs.KafkaConfig) Client

New create a kafka client

type Consumer

type Consumer interface {
	Close() error
	Run(ctx context.Context)
}

Consumer kafka consumer interface

type Message

type Message = kafka.Message

Message kafka message body