package
9.0.0-beta.1.pre+incompatible
Repository: https://github.com/pingcap/ticdc.git
Documentation: pkg.go.dev

# Functions

Gokrb5v8 uses gokrb5/v8 to implement the GSSAPI mechanism.
NewFactory returns a factory implemented based on kafka-go.
NewMetricsCollector return a kafka metrics collector.

# Constants

TokIDKrbApReq https://tools.ietf.org/html/rfc4121#section-4.1.

# Structs

MetricsCollector is the kafka metrics collector based on kafka-go library.
StartWithoutHostError is the error type for when Start is called on the GSSAPI mechanism without the host having been set by WithHost.

# Interfaces

Client is the interface of the kafka-go client, it contains a subset of all methods which is used by the kafka sink.
Gokrb5v8Client is the client for gokrbv8.