Browse Source

chore: rename custom kafka client to avoid package name issues

chore/proposed-structure
Blaz Smehov 4 weeks ago
parent
commit
7b60a02f02
3 changed files with 3 additions and 3 deletions
  1. +1
    -1
      internal/pkg/kafkaclient/consumer.go
  2. +1
    -1
      internal/pkg/kafkaclient/reader.go
  3. +1
    -1
      internal/pkg/kafkaclient/writer.go

internal/pkg/kafka/consumer.go → internal/pkg/kafkaclient/consumer.go View File

@@ -1,4 +1,4 @@
package kafka
package kafkaclient


import ( import (
"context" "context"

internal/pkg/kafka/reader.go → internal/pkg/kafkaclient/reader.go View File

@@ -1,4 +1,4 @@
package kafka
package kafkaclient


import ( import (
"strings" "strings"

internal/pkg/kafka/writer.go → internal/pkg/kafkaclient/writer.go View File

@@ -1,4 +1,4 @@
package kafka
package kafkaclient


import ( import (
"time" "time"

Loading…
Cancel
Save