MCPcopy
hub / github.com/IBM/sarama / SendMessage

Method SendMessage

sync_producer.go:26–26  ·  view source on GitHub ↗

SendMessage produces a given message, and returns only when it either has succeeded or failed to produce. It will return the partition and the offset of the produced message, or an error if the message failed to produce.

(msg *ProducerMessage)

Source from the content-addressed store, hash-verified

24 // succeeded or failed to produce. It will return the partition and the offset
25 // of the produced message, or an error if the message failed to produce.
26 SendMessage(msg *ProducerMessage) (partition int32, offset int64, err error)
27
28 // SendMessages produces a given set of messages, and returns only when all
29 // messages in the set have either succeeded or failed. Note that messages

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls