kafka

Documentation

Index

• func NewProducerConfig() *sarama.Config
• type Producer
  • func NewProducer(brokers []string, config *sarama.Config) (*Producer, error)
  • func (k *Producer) Close() error
• type RequestMessage

Functions

func NewProducerConfig

func NewProducerConfig() *sarama.Config

Types

type Producer

type Producer struct {
	sarama.SyncProducer
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer(brokers []string, config *sarama.Config) (*Producer, error)

func (*Producer) Close

func (k *Producer) Close() error

type RequestMessage

type RequestMessage struct {
	Type      int    `json:"type"`
	CompanyId int    `json:"companyId"`
	Price     int    `json:"price"`
	DateTime  string `json:"datetime"`
}