Merge branch 'main' of https://github.com/Roshick/go-autumn-kafka

Roshick · Dec 6, 2023 · e13949a · e13949a
2 parents 913a25d + 03e0dca
commit e13949a
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 2 deletions.
diff --git a/pkg/aukafka/config.go → pkg/kafka/config.go b/pkg/aukafka/config.go → pkg/kafka/config.go
diff --git a/pkg/aukafka/consumer.go → pkg/kafka/consumer.go b/pkg/aukafka/consumer.go → pkg/kafka/consumer.go
@@ -17,7 +17,7 @@ type Consumer[E any] struct {
 	receiveCallback func(ctx context.Context, key *string, event *E, timestamp time.Time) error
 }
 
-func CreateConsumer[E any](
+func NewConsumer[E any](
 	ctx context.Context,
 	topicConfig TopicConfig,
 	receiveCallback func(context.Context, *string, *E, time.Time) error,

diff --git a/pkg/aukafka/producer_sync.go → pkg/kafka/producer_sync.go b/pkg/aukafka/producer_sync.go → pkg/kafka/producer_sync.go
@@ -14,7 +14,7 @@ type SyncProducer[V any] struct {
 	topic  string
 }
 
-func CreateSyncProducer[V any](
+func NewSyncProducer[V any](
 	_ context.Context,
 	topicConfig TopicConfig,
 	configPreset *sarama.Config,

diff --git a/pkg/aukafka/scramclient.go → pkg/kafka/scramclient.go b/pkg/aukafka/scramclient.go → pkg/kafka/scramclient.go