kafkapublisher

Documentation

Index

• Constants
• func DefaultSaramaConfig() *sarama.Config
• func New(producerOpt ProducerOption, opts ...Option) (easypubsub.Publisher, error)
• type MarshalMsgFunc
• type Option
  • func WithLogger(logger easypubsub.Logger) Option
  • func WithMarshalMsgFunc(marshalMsgFunc MarshalMsgFunc) Option
• type ProducerOption
  • func AsyncProducer(brokers []string, config *sarama.Config) ProducerOption
  • func SyncProducer(brokers []string, config *sarama.Config) ProducerOption
• type PublishResult
• type Publisher
  • func (pub *Publisher) Close() error
  • func (pub *Publisher) Publish(topic string, msg *easypubsub.Message) (result *easypubsub.PublishResult)
  • func (pub *Publisher) String() string

Constants

const (
	NORMAL = 0
	CLOSED = 1
)

Functions

func DefaultSaramaConfig

func DefaultSaramaConfig() *sarama.Config

func New

func New(producerOpt ProducerOption, opts ...Option) (easypubsub.Publisher, error)

Types

type MarshalMsgFunc

type MarshalMsgFunc func(topic string, msg *easypubsub.Message) (*sarama.ProducerMessage, error)

type Option

type Option func(o *options)

func WithLogger

func WithLogger(logger easypubsub.Logger) Option

func WithMarshalMsgFunc

func WithMarshalMsgFunc(marshalMsgFunc MarshalMsgFunc) Option

type ProducerOption

type ProducerOption func(o *producerOptions)

func AsyncProducer

func AsyncProducer(brokers []string, config *sarama.Config) ProducerOption

func SyncProducer

func SyncProducer(brokers []string, config *sarama.Config) ProducerOption

type PublishResult

type PublishResult struct {
	Partition int32
	Offset    int64
}

type Publisher

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

func (*Publisher) Close

func (pub *Publisher) Close() error

func (*Publisher) Publish

func (pub *Publisher) Publish(topic string, msg *easypubsub.Message) (result *easypubsub.PublishResult)

func (*Publisher) String

func (pub *Publisher) String() string