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
Source Files
Click to show internal directories.
Click to hide internal directories.