kafka-go: github.com/segmentio/kafka-go/testing Index | Files

package kafka

import "github.com/segmentio/kafka-go/testing"

Index

Package Files

version.go

func KafkaIsAtLeast Uses

func KafkaIsAtLeast(semver string) bool

KafkaIsAtLeast returns true when the test broker is running a protocol version that is semver or newer. It determines the broker's version using the `KAFKA_VERSION` environment variable. If the var is unset, then this function will return true.

Package kafka imports 3 packages (graph). Updated 2019-06-25. Refresh now. Tools for package owners.