Documentation ¶
Index ¶
- Variables
- func CreateAsyncProducer(idempotent bool) (sarama.AsyncProducer, error)
- func CreateProducer(idempotent bool) (sarama.SyncProducer, error)
- func SendSyncMessage(topic, key, value, headers, metadata string, offset int64, partition int32, ...) (partitionResult int32, offsetResult int64, err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var Address []string
Functions ¶
func CreateAsyncProducer ¶
func CreateAsyncProducer(idempotent bool) (sarama.AsyncProducer, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.