kafka

Documentation

Index

• func Key(key string) broker.PublishOption
• func New(opts ...b.Option) b.Broker
• func PublishConfig(c *sarama.Config) broker.Option
• func SubscribeConfig(c *sarama.Config) broker.Option
• type Kafka
  • func (broker *Kafka) Address() string
  • func (broker *Kafka) Connect() error
  • func (broker *Kafka) Disconnect() error
  • func (broker *Kafka) Init(opts ...b.Option) error
  • func (broker *Kafka) Options() b.Options
  • func (broker *Kafka) Publish(ctx context.Context, topic string, msg *b.Message, opts ...b.PublishOption) error
  • func (broker *Kafka) String() string
  • func (broker *Kafka) Subscribe(topic string, h b.Handler, opts ...b.SubscribeOption) (b.Subscriber, error)
• type SendMessageResponse

Functions

func Key

func Key(key string) broker.PublishOption

Key The partitioning key for this message. Pre-existing Encoders include StringEncoder.

func New

func New(opts ...b.Option) b.Broker

func PublishConfig

func PublishConfig(c *sarama.Config) broker.Option

func SubscribeConfig

func SubscribeConfig(c *sarama.Config) broker.Option

Types

type Kafka

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

func (*Kafka) Address

func (broker *Kafka) Address() string

func (*Kafka) Connect

func (broker *Kafka) Connect() error

func (*Kafka) Disconnect

func (broker *Kafka) Disconnect() error

func (*Kafka) Init

func (broker *Kafka) Init(opts ...b.Option) error

func (*Kafka) Options

func (broker *Kafka) Options() b.Options

func (*Kafka) Publish

func (broker *Kafka) Publish(ctx context.Context, topic string, msg *b.Message, opts ...b.PublishOption) error

func (*Kafka) String

func (broker *Kafka) String() string

func (*Kafka) Subscribe

func (broker *Kafka) Subscribe(topic string, h b.Handler, opts ...b.SubscribeOption) (b.Subscriber, error)

type SendMessageResponse

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