kafka

type Config struct {
	Brokers string `mapstructure:"brokers" validate:"required"`
	Topic   string `mapstructure:"topic" validate:"required"`
	KeyPath string `mapstructure:"key_path"`
}

type ProtoReflector interface {
	ProtoReflect() protoreflect.Message
}

type Sink struct {
	plugins.BasePlugin
	// contains filtered or unexported fields
}