Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MurmurHasher ¶
MurmurHasher creates murmur2 hasher implementing hash.Hash32 interface. The implementation is not full and does not support streaming. It only implements the interface to comply with sarama.NewCustomHashPartitioner signature. But Sarama only uses Write method once, when writing keys and values of the message, so streaming support is not necessary.
func NewConsumer ¶
NewConsumer configures and returns a cluster-consumer
func NewJVMCompatiblePartitioner ¶
func NewJVMCompatiblePartitioner(topic string) sarama.Partitioner
NewJVMCompatiblePartitioner creates a Sarama partitioner that uses the same hashing algorithm as JVM Kafka clients.
func NewProducer ¶
func NewProducer(brokers []string, hasher, compressionType string) sarama.AsyncProducer
NewProducer configures and returns an async producer
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.