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.