func MyTopic(name string) (topic Topic) {
	return Topic{
		Name:               name,
		ServiceEndpointMap: make(ServiceEndpointMap),
	}
}
MyTopic returns a new Topic instance
package server
import (
	"encoding/json"
	"go-micro-framework/microservice/configuration"
	"go-micro-framework/microservice/endpoint"
	"runtime"
	"strconv"
	"github.com/Shopify/sarama"
	log "github.com/sirupsen/logrus"
)
func funcName() string {
	pc, _, _, _ := runtime.Caller(1)
	file, line := runtime.FuncForPC(pc).FileLine(pc)
	return runtime.FuncForPC(pc).Name() + "::" + file + "::" + strconv.Itoa(line)
}
type KafkaConsumer struct {
	cfg    *configuration.KafkaConfig
	config *sarama.Config
	master sarama.Consumer
	topics map[string]Topic
	quit   chan bool
}
type Topic struct {
	Name               string
	ServiceEndpointMap ServiceEndpointMap
}