Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MessagePayload ¶
type MessagePayload struct { MessageNumber int `json:"message_number"` Timestamp string `json:"timestamp"` }
MessagePayload the JSON representation of the produced messages
type SeqProducer ¶
type SeqProducer struct { Producer kafkaProducer // contains filtered or unexported fields }
SeqProducer concrete ordered producer
func NewProducer ¶
func NewProducer(cfg *config.Config) (*SeqProducer, error)
NewProducer returns a new and configured SeqProducer
func (*SeqProducer) Run ¶
func (sp *SeqProducer) Run() error
Run runs the producer for sending configured messages
Click to show internal directories.
Click to hide internal directories.