From 0e510889122fc1f0b6e841ed9436813156664f24 Mon Sep 17 00:00:00 2001 From: Abdulsametileri Date: Tue, 3 Oct 2023 09:49:22 +0300 Subject: [PATCH] chore: change otel-kafka-konsumer path to Trendyol org --- consumer_base.go | 2 +- examples/with-tracing/README.md | 2 +- go.mod | 2 +- go.sum | 4 ++-- otel_producer.go | 2 +- otel_reader_wrapper.go | 2 +- test/integration/go.mod | 2 +- test/integration/go.sum | 4 ++-- 8 files changed, 10 insertions(+), 10 deletions(-) diff --git a/consumer_base.go b/consumer_base.go index 8eb0574..da1a59c 100644 --- a/consumer_base.go +++ b/consumer_base.go @@ -4,7 +4,7 @@ import ( "context" "sync" - "github.com/Abdulsametileri/otel-kafka-konsumer" + "github.com/Trendyol/otel-kafka-konsumer" "go.opentelemetry.io/otel/propagation" "github.com/prometheus/client_golang/prometheus" diff --git a/examples/with-tracing/README.md b/examples/with-tracing/README.md index 33ae089..ea1269b 100644 --- a/examples/with-tracing/README.md +++ b/examples/with-tracing/README.md @@ -2,7 +2,7 @@ [segmentio/kafka-go](https://github.com/segmentio/kafka-go) has no support for open telemetry. There is also an [issue](https://github.com/segmentio/kafka-go/issues/1025) about it. -Based on some work on that issue, we created a project called [otel-kafka-konsumer](https://github.com/Abdulsametileri/otel-kafka-konsumer). +Based on some work on that issue, we created a project called [otel-kafka-konsumer](https://github.com/Trendyol/otel-kafka-konsumer). By integrating this project with kafka-konsumer, we successfully implemented distributed tracing in consuming and producing operations. You can run demo. diff --git a/go.mod b/go.mod index 04b7ff6..eaea1a2 100644 --- a/go.mod +++ b/go.mod @@ -3,8 +3,8 @@ module github.com/Trendyol/kafka-konsumer go 1.19 require ( - github.com/Abdulsametileri/otel-kafka-konsumer v0.0.2 github.com/Trendyol/kafka-cronsumer v1.3.3 + github.com/Trendyol/otel-kafka-konsumer v0.0.4 github.com/ansrivas/fiberprometheus/v2 v2.6.1 github.com/gofiber/fiber/v2 v2.48.0 github.com/prometheus/client_golang v1.16.0 diff --git a/go.sum b/go.sum index ca230aa..3dc1e39 100644 --- a/go.sum +++ b/go.sum @@ -1,7 +1,7 @@ -github.com/Abdulsametileri/otel-kafka-konsumer v0.0.2 h1:tT//WZhqhufdxYLRPnsqdZxb24GtzWYydJY89aj3JUE= -github.com/Abdulsametileri/otel-kafka-konsumer v0.0.2/go.mod h1:/3dwU6SH3KI/LCoyzHXmqJ5n8M+mbE/AvgJ+zEO/+Tk= github.com/Trendyol/kafka-cronsumer v1.3.3 h1:KNlX/L4bDkpNAXTqHUQNrnkC/kauL6djKp0tuOFny8Y= github.com/Trendyol/kafka-cronsumer v1.3.3/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU= +github.com/Trendyol/otel-kafka-konsumer v0.0.4 h1:W9tt/DXs6MGSvqXWJU13ui+UzJZmVBrGafAefaV9JBM= +github.com/Trendyol/otel-kafka-konsumer v0.0.4/go.mod h1:zdCaFclzRCO9fzcjxkHrWOB3I2+uTPrmkq4zczkD1F0= github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/cCs= github.com/andybalholm/brotli v1.0.5/go.mod h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig= github.com/ansrivas/fiberprometheus/v2 v2.6.1 h1:wac3pXaE6BYYTF04AC6K0ktk6vCD+MnDOJZ3SK66kXM= diff --git a/otel_producer.go b/otel_producer.go index ac1e84a..83931a5 100644 --- a/otel_producer.go +++ b/otel_producer.go @@ -4,7 +4,7 @@ import ( "context" "fmt" - "github.com/Abdulsametileri/otel-kafka-konsumer" + "github.com/Trendyol/otel-kafka-konsumer" segmentio "github.com/segmentio/kafka-go" "go.opentelemetry.io/otel/attribute" semconv "go.opentelemetry.io/otel/semconv/v1.19.0" diff --git a/otel_reader_wrapper.go b/otel_reader_wrapper.go index 769102f..0fa07a5 100644 --- a/otel_reader_wrapper.go +++ b/otel_reader_wrapper.go @@ -3,7 +3,7 @@ package kafka import ( "context" - "github.com/Abdulsametileri/otel-kafka-konsumer" + "github.com/Trendyol/otel-kafka-konsumer" segmentio "github.com/segmentio/kafka-go" "go.opentelemetry.io/otel/attribute" semconv "go.opentelemetry.io/otel/semconv/v1.19.0" diff --git a/test/integration/go.mod b/test/integration/go.mod index 35c2f12..e5292b3 100644 --- a/test/integration/go.mod +++ b/test/integration/go.mod @@ -10,7 +10,7 @@ require ( ) require ( - github.com/Abdulsametileri/otel-kafka-konsumer v0.0.0 // indirect + github.com/Trendyol/otel-kafka-konsumer v0.0.0 // indirect github.com/Trendyol/kafka-cronsumer v1.3.3 // indirect github.com/andybalholm/brotli v1.0.5 // indirect github.com/ansrivas/fiberprometheus/v2 v2.6.1 // indirect diff --git a/test/integration/go.sum b/test/integration/go.sum index f028471..c582be8 100644 --- a/test/integration/go.sum +++ b/test/integration/go.sum @@ -1,5 +1,5 @@ -github.com/Abdulsametileri/otel-kafka-konsumer v0.0.0 h1:5iLegl3ZoOVAIgua/ne5OrTwYITLz+4EhbK7i/orXOw= -github.com/Abdulsametileri/otel-kafka-konsumer v0.0.0/go.mod h1:SOtgXp7znhCuI/+F4by91/0JWLfFqcZyYd1x9EtoxUU= +github.com/Trendyol/otel-kafka-konsumer v0.0.0 h1:5iLegl3ZoOVAIgua/ne5OrTwYITLz+4EhbK7i/orXOw= +github.com/Trendyol/otel-kafka-konsumer v0.0.0/go.mod h1:SOtgXp7znhCuI/+F4by91/0JWLfFqcZyYd1x9EtoxUU= github.com/Trendyol/kafka-cronsumer v1.3.3 h1:KNlX/L4bDkpNAXTqHUQNrnkC/kauL6djKp0tuOFny8Y= github.com/Trendyol/kafka-cronsumer v1.3.3/go.mod h1:VpweJmKY+6dppFhzWOZDbZfxBNuJkSxB12CcuZWBNFU= github.com/andybalholm/brotli v1.0.5 h1:8uQZIdzKmjc/iuPu7O2ioW48L81FgatrcpfFmiq/cCs=