kafka

package

v1.9.0 Latest Latest Go to latest Published: Oct 24, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Package kafka is the native client probe for kafka.

View Source

const Kind string = "Kafka"

Kind is the type of driver

This section is empty.

This section is empty.

type Kafka struct {
	conf.Options `yaml:",inline"`

	Context context.Context `yaml:"-" json:"-"`
	// contains filtered or unexported fields
}

Kafka is the Kafka client

func New(opt conf.Options) (*Kafka, error)

New create a Kafka client

func (k *Kafka) Kind() string

Kind return the name of client

func (k *Kafka) Probe() (bool, string)

Probe do the health check