Documentation ¶
Index ¶
- Variables
- func Config(version sarama.KafkaVersion, nodes []string) (cfg *sarama.Config)
- func NewAdmin(cfg *sarama.Config) (admin sarama.ClusterAdmin, cancel func(), e error)
- func NewConfig() (cfg *sarama.Config)
- func NewConsumer(cfg *sarama.Config, topicDir, topic string) (offset int64, consumer sarama.PartitionConsumer, cancel func(), ...)
- type Producer
Constants ¶
This section is empty.
Variables ¶
View Source
var KafkaV2_5_0_0 = sarama.V2_5_0_0
Functions ¶
func NewAdmin ¶
func NewAdmin(cfg *sarama.Config) (admin sarama.ClusterAdmin, cancel func(), e error)
func NewConsumer ¶
Types ¶
type Producer ¶
type Producer struct {
This sarama.AsyncProducer
}
Click to show internal directories.
Click to hide internal directories.