change to original eventapimanger naming

eventing/kafka/manager.go

@@ -8,7 +8,7 @@ import (
 	"github.com/confluentinc/confluent-kafka-go/v2/kafka"
 	"github.com/go-kratos/kratos/v2/log"
 	"github.com/google/uuid"
-	eventingapi "github.com/project-kessel/inventory-api/eventing/api"
+	api "github.com/project-kessel/inventory-api/eventing/api"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/attribute"
 	"go.opentelemetry.io/otel/metric"
@@ -93,7 +93,7 @@ func (m *KafkaManager) Errs() <-chan error {
 }
 
 // Lookup figures out which topic should be used for the given identity and resource.
-func (m *KafkaManager) Lookup(identity *authnapi.Identity, resource_type string, resource_id uuid.UUID) (eventingapi.Producer, error) {
+func (m *KafkaManager) Lookup(identity *authnapi.Identity, resource_type string, resource_id uuid.UUID) (api.Producer, error) {
 
 	// there is no complicated topic dispatch logic... for now.
 	producer, err := NewProducer(m, m.Config.DefaultTopic, identity)
@@ -139,7 +139,7 @@ func NewProducer(manager *KafkaManager, topic string, identity *authnapi.Identit
 }
 
 // Produce creates the cloud event and sends it on the Kafka Topic
-func (p *kafkaProducer) Produce(ctx context.Context, event *eventingapi.Event) error {
+func (p *kafkaProducer) Produce(ctx context.Context, event *api.Event) error {
 	e := cloudevents.NewEvent()
 
 	e.SetSpecVersion(cloudevents.VersionV1)