Skip to content

Commit

Permalink
chore: change otel-kafka-konsumer path to Trendyol org
Browse files Browse the repository at this point in the history
  • Loading branch information
Abdulsametileri committed Oct 3, 2023
1 parent 70aaf51 commit 0e51088
Show file tree
Hide file tree
Showing 8 changed files with 10 additions and 10 deletions.
2 changes: 1 addition & 1 deletion consumer_base.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
2 changes: 1 addition & 1 deletion examples/with-tracing/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
@@ -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=
Expand Down
2 changes: 1 addition & 1 deletion otel_producer.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
2 changes: 1 addition & 1 deletion otel_reader_wrapper.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
2 changes: 1 addition & 1 deletion test/integration/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
4 changes: 2 additions & 2 deletions test/integration/go.sum
Original file line number Diff line number Diff line change
@@ -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=
Expand Down

0 comments on commit 0e51088

Please sign in to comment.