diff --git a/config/config.go b/config/config.go index 807ee8f..781d0a0 100644 --- a/config/config.go +++ b/config/config.go @@ -1,9 +1,10 @@ package config import ( - "godcpkafkaconnector/logger" "time" + "github.com/Trendyol/go-kafka-connect-couchbase/logger" + "github.com/gookit/config/v2" "github.com/gookit/config/v2/yamlv3" ) diff --git a/connector.go b/connector.go index c717325..2d45039 100644 --- a/connector.go +++ b/connector.go @@ -1,13 +1,13 @@ -package godcpkafkaconnector +package gokafkaconnectcouchbase import ( "context" - "godcpkafkaconnector/config" - "godcpkafkaconnector/couchbase" - kafka "godcpkafkaconnector/kafka/producer" - "godcpkafkaconnector/logger" godcpclient "github.com/Trendyol/go-dcp-client" + "github.com/Trendyol/go-kafka-connect-couchbase/config" + "github.com/Trendyol/go-kafka-connect-couchbase/couchbase" + kafka "github.com/Trendyol/go-kafka-connect-couchbase/kafka/producer" + "github.com/Trendyol/go-kafka-connect-couchbase/logger" ) type Connector interface { diff --git a/example/main.go b/example/main.go index c59acb8..6580668 100644 --- a/example/main.go +++ b/example/main.go @@ -1,9 +1,8 @@ package main import ( - "godcpkafkaconnector" - "godcpkafkaconnector/couchbase" - "godcpkafkaconnector/kafka" + "github.com/Trendyol/go-kafka-connect-couchbase/couchbase" + "github.com/Trendyol/go-kafka-connect-couchbase/kafka" ) func mapper(event *couchbase.Event) *kafka.Message { diff --git a/go.mod b/go.mod index 5c154c0..190cbbb 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module godcpkafkaconnector +module github.com/Trendyol/go-kafka-connect-couchbase go 1.19 diff --git a/json_config.go b/json_config.go index ce02e90..10103b2 100644 --- a/json_config.go +++ b/json_config.go @@ -1,4 +1,4 @@ -package godcpkafkaconnector +package gokafkaconnectcouchbase import "github.com/json-iterator/go" diff --git a/kafka/producer/producer.go b/kafka/producer/producer.go index 6a2942f..493652c 100644 --- a/kafka/producer/producer.go +++ b/kafka/producer/producer.go @@ -2,12 +2,13 @@ package kafka import ( "context" - "godcpkafkaconnector/config" - "godcpkafkaconnector/logger" "math" "strings" "time" + "github.com/Trendyol/go-kafka-connect-couchbase/config" + "github.com/Trendyol/go-kafka-connect-couchbase/logger" + "github.com/segmentio/kafka-go" ) diff --git a/kafka/producer/producerbatch.go b/kafka/producer/producer_batch.go similarity index 97% rename from kafka/producer/producerbatch.go rename to kafka/producer/producer_batch.go index 5f8e87c..902e3a1 100644 --- a/kafka/producer/producerbatch.go +++ b/kafka/producer/producer_batch.go @@ -2,10 +2,11 @@ package kafka import ( "context" - "godcpkafkaconnector/logger" "sync" "time" + "github.com/Trendyol/go-kafka-connect-couchbase/logger" + "github.com/segmentio/kafka-go" ) diff --git a/mapper.go b/mapper.go index f146629..fa973de 100644 --- a/mapper.go +++ b/mapper.go @@ -1,8 +1,8 @@ -package godcpkafkaconnector +package gokafkaconnectcouchbase import ( - "godcpkafkaconnector/couchbase" - "godcpkafkaconnector/kafka" + "github.com/Trendyol/go-kafka-connect-couchbase/couchbase" + "github.com/Trendyol/go-kafka-connect-couchbase/kafka" ) type Mapper func(event *couchbase.Event) *kafka.Message