metrictank: github.com/grafana/metrictank/kafka Index | Files

package kafka

import "github.com/grafana/metrictank/kafka"

Index

Package Files

partitions.go

func DiffPartitions Uses

func DiffPartitions(a []int32, b []int32) []int32

returns elements that are in a but not in b

func GetPartitions Uses

func GetPartitions(client sarama.Client, topics []string) ([]int32, error)

Package kafka imports 2 packages (graph) and is imported by 6 packages. Updated 2018-11-02. Refresh now. Tools for package owners.