partitioner

Documentation

Index

• type Kafka
  • func NewKafka(partitionBy string) (*Kafka, error)
  • func (k *Kafka) GetPartitionKey(m schema.PartitionedMetric, b []byte) ([]byte, error)
  • func (k *Kafka) Partition(m schema.PartitionedMetric, numPartitions int32) (int32, error)
• type Partitioner

Types

type Kafka

type Kafka struct {
	PartitionBy string
	Partitioner sarama.Partitioner
}

func NewKafka

func NewKafka(partitionBy string) (*Kafka, error)

func (*Kafka) GetPartitionKey

func (k *Kafka) GetPartitionKey(m schema.PartitionedMetric, b []byte) ([]byte, error)

func (*Kafka) Partition

func (k *Kafka) Partition(m schema.PartitionedMetric, numPartitions int32) (int32, error)

type Partitioner

type Partitioner interface {
	Partition(schema.PartitionedMetric, int32) (int32, error)
}