plugins

type KafkaMessageAttr struct {
	// contains filtered or unexported fields
}

type KafkaUpstream struct {
	// Embed the default plugin here,
	// so that we don't need to reimplement all the methods.
	plugin.Plugin
}

type KafkaUpstreamConf struct {
	Conf         map[string]interface{} `json:"config"`
	JsonKey      string                 `json:"jsonkey"`
	Topic        string                 `json:"topic"`
	Partition    int32                  `json:"partition"`
	Key          string                 `json:"key"`
	HeaderPrefix string                 `json:"headerprefix"`
}

type KafkaUpstreamResponse struct {
	Message string `json:"message"`
	Code    int    `json:"code"`
}