beats: github.com/elastic/beats/libbeat/common/kafka Index | Files

package kafka

import "github.com/elastic/beats/libbeat/common/kafka"

Index

Package Files

version.go

type Version Uses

type Version string

Version is a kafka version

func (Version) Get Uses

func (v Version) Get() (sarama.KafkaVersion, bool)

Get a sarama kafka version

func (*Version) Unpack Uses

func (v *Version) Unpack(s string) error

Unpack a kafka version

func (*Version) Validate Uses

func (v *Version) Validate() error

Validate that a kafka version is among the possible options

Package kafka imports 2 packages (graph) and is imported by 21 packages. Updated 2019-03-19. Refresh now. Tools for package owners.