vnf_kafka

type KafkaConnectionConfig struct {
	PConfigMap *kafka.ConfigMap
	CConfigMap *kafka.ConfigMap
	CTopics    []string
}

type KafkaHandler interface {
	//request
	Hello(*kafka.Producer, *pb.Msg)
	GetData(*kafka.Producer, *pb.Msg)
	ReplaceConfig(*kafka.Producer, *pb.Msg)
	UpdateConfig(*kafka.Producer, *pb.Msg)
	RPC(*kafka.Producer, *pb.Msg)
	Action(*kafka.Producer, *pb.Msg)

	Notification(*kafka.Producer, *pb.Msg)
}

type UnimplementedKafkaHandler struct{}