diff --git a/internal/pkg/kafka/consumer.go b/internal/pkg/kafkaclient/consumer.go
similarity index 95%
rename from internal/pkg/kafka/consumer.go
rename to internal/pkg/kafkaclient/consumer.go
index 59e6da9..9e6b8c5 100644
--- a/internal/pkg/kafka/consumer.go
+++ b/internal/pkg/kafkaclient/consumer.go
@@ -1,4 +1,4 @@
-package kafka
+package kafkaclient
 
 import (
 	"context"
diff --git a/internal/pkg/kafka/reader.go b/internal/pkg/kafkaclient/reader.go
similarity index 93%
rename from internal/pkg/kafka/reader.go
rename to internal/pkg/kafkaclient/reader.go
index e5e379a..dbd5e07 100644
--- a/internal/pkg/kafka/reader.go
+++ b/internal/pkg/kafkaclient/reader.go
@@ -1,4 +1,4 @@
-package kafka
+package kafkaclient
 
 import (
 	"strings"
diff --git a/internal/pkg/kafka/writer.go b/internal/pkg/kafkaclient/writer.go
similarity index 93%
rename from internal/pkg/kafka/writer.go
rename to internal/pkg/kafkaclient/writer.go
index a1fa619..fe42d5d 100644
--- a/internal/pkg/kafka/writer.go
+++ b/internal/pkg/kafkaclient/writer.go
@@ -1,4 +1,4 @@
-package kafka
+package kafkaclient
 
 import (
 	"time"