Versions in this module Expand all Collapse all v1 v1.0.0 Jul 30, 2020 Changes in this version + type KafkaMdm struct + func New(topic string, brokers []string, codec string, timeout time.Duration, ...) (*KafkaMdm, error) + func (k *KafkaMdm) Close() error + func (k *KafkaMdm) Flush(metrics []*schema.MetricData) error + type LastNumPartitioner struct + func (p *LastNumPartitioner) Partition(m schema.PartitionedMetric, numPartitions int32) (int32, error)
Go to main page