Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Producer ¶
type Producer struct { sync.Mutex // For now we use SyncProducer to provide simplicity and an easy-to-understand // example. Before putting into production or any perf testing, we need to // change this to async and probably refactor the data path to have a // seprate Producer thread for each http connection (and a shared schema // manager). For now, any parallel connections share a single producer. // XXX note: change this to sarama.AsyncProducer Producer sarama.SyncProducer // contains filtered or unexported fields }
func NewProducer ¶
Click to show internal directories.
Click to hide internal directories.