kafkax

Documentation

Index

• func Config(v *viper.Viper)
• type Client
  • func New(name string, cfg ...*sarama.Config) (Client, error)

Functions

func Config

func Config(v *viper.Viper)

Types

type Client

type Client interface {
	// Get get kafka client
	Get() sarama.Client

	// Close close kafka client
	Close() error

	// SendMessage send message to kafka
	SendMessage(ctx context.Context, message *sarama.ProducerMessage) error

	// GroupConsume consume kafka group
	GroupConsume(ctx context.Context, group string, topics []string, handler sarama.ConsumerGroupHandler) error
}

Client is a kafka client wrapper

func New

func New(name string, cfg ...*sarama.Config) (Client, error)

New create a kafka client