Skip to content

Commit

Permalink
feat: bump go-dcp v1.1.13
Browse files Browse the repository at this point in the history
  • Loading branch information
@erayarslan
erayarslan committed Nov 16, 2023
1 parent 38452e4 commit ec651c9
Show file tree
Hide file tree
Showing 15 changed files with 24 additions and 24 deletions.
2 changes: 1 addition & 1 deletion example/default-mapper/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ replace github.com/Trendyol/go-dcp-kafka => ./../..
require github.com/Trendyol/go-dcp-kafka v0.0.0

require (
github.com/Trendyol/go-dcp v1.1.12 // indirect
github.com/Trendyol/go-dcp v1.1.13 // indirect
github.com/andybalholm/brotli v1.0.5 // indirect
github.com/ansrivas/fiberprometheus/v2 v2.6.1 // indirect
github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef // indirect
Expand Down
4 changes: 2 additions & 2 deletions example/default-mapper/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8=
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
github.com/Microsoft/hcsshim v0.11.1 h1:hJ3s7GbWlGK4YVV92sO88BQSyF4ZLVy7/awqOlPxFbA=
github.com/Trendyol/go-dcp v1.1.12 h1:eRdP4W2k9wt3KcoszGrGCJD31uYXdUlWApf77g9uFzg=
github.com/Trendyol/go-dcp v1.1.12/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
github.com/Trendyol/go-dcp v1.1.13 h1:g4Ku+I5Gx+jQcxaysdEE7bOZzRVbqfLxZBSQplPVjR4=
github.com/Trendyol/go-dcp v1.1.13/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
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 example/simple-logger/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ require (
)

require (
github.com/Trendyol/go-dcp v1.1.12 // indirect
github.com/Trendyol/go-dcp v1.1.13 // indirect
github.com/andybalholm/brotli v1.0.5 // indirect
github.com/ansrivas/fiberprometheus/v2 v2.6.1 // indirect
github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef // indirect
Expand Down
4 changes: 2 additions & 2 deletions example/simple-logger/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8=
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
github.com/Microsoft/hcsshim v0.11.1 h1:hJ3s7GbWlGK4YVV92sO88BQSyF4ZLVy7/awqOlPxFbA=
github.com/Trendyol/go-dcp v1.1.12 h1:eRdP4W2k9wt3KcoszGrGCJD31uYXdUlWApf77g9uFzg=
github.com/Trendyol/go-dcp v1.1.12/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
github.com/Trendyol/go-dcp v1.1.13 h1:g4Ku+I5Gx+jQcxaysdEE7bOZzRVbqfLxZBSQplPVjR4=
github.com/Trendyol/go-dcp v1.1.13/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
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 example/simple/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ replace github.com/Trendyol/go-dcp-kafka => ./../..
require github.com/Trendyol/go-dcp-kafka v0.0.0

require (
github.com/Trendyol/go-dcp v1.1.12 // indirect
github.com/Trendyol/go-dcp v1.1.13 // indirect
github.com/andybalholm/brotli v1.0.5 // indirect
github.com/ansrivas/fiberprometheus/v2 v2.6.1 // indirect
github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef // indirect
Expand Down
4 changes: 2 additions & 2 deletions example/simple/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8=
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
github.com/Microsoft/hcsshim v0.11.1 h1:hJ3s7GbWlGK4YVV92sO88BQSyF4ZLVy7/awqOlPxFbA=
github.com/Trendyol/go-dcp v1.1.12 h1:eRdP4W2k9wt3KcoszGrGCJD31uYXdUlWApf77g9uFzg=
github.com/Trendyol/go-dcp v1.1.12/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
github.com/Trendyol/go-dcp v1.1.13 h1:g4Ku+I5Gx+jQcxaysdEE7bOZzRVbqfLxZBSQplPVjR4=
github.com/Trendyol/go-dcp v1.1.13/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
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 example/struct-config/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ go 1.19
replace github.com/Trendyol/go-dcp-kafka => ./../..

require (
github.com/Trendyol/go-dcp v1.1.12
github.com/Trendyol/go-dcp v1.1.13
github.com/Trendyol/go-dcp-kafka v0.0.0
)

Expand Down
4 changes: 2 additions & 2 deletions example/struct-config/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8=
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
github.com/Microsoft/hcsshim v0.11.1 h1:hJ3s7GbWlGK4YVV92sO88BQSyF4ZLVy7/awqOlPxFbA=
github.com/Trendyol/go-dcp v1.1.12 h1:eRdP4W2k9wt3KcoszGrGCJD31uYXdUlWApf77g9uFzg=
github.com/Trendyol/go-dcp v1.1.12/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
github.com/Trendyol/go-dcp v1.1.13 h1:g4Ku+I5Gx+jQcxaysdEE7bOZzRVbqfLxZBSQplPVjR4=
github.com/Trendyol/go-dcp v1.1.13/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
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 example/struct-config/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ func main() {
},
},
Metadata: dcpConfig.Metadata{
Config: map[string]any{
Config: map[string]string{
"bucket": "checkpoint-bucket-name",
"scope": "_default",
"collection": "_default",
Expand Down
2 changes: 1 addition & 1 deletion go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ module github.com/Trendyol/go-dcp-kafka
go 1.19

require (
github.com/Trendyol/go-dcp v1.1.12
github.com/Trendyol/go-dcp v1.1.13
github.com/json-iterator/go v1.1.12
github.com/prometheus/client_golang v1.17.0
github.com/segmentio/kafka-go v0.4.42
Expand Down
4 changes: 2 additions & 2 deletions go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8=
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
github.com/Microsoft/hcsshim v0.11.1 h1:hJ3s7GbWlGK4YVV92sO88BQSyF4ZLVy7/awqOlPxFbA=
github.com/Trendyol/go-dcp v1.1.12 h1:eRdP4W2k9wt3KcoszGrGCJD31uYXdUlWApf77g9uFzg=
github.com/Trendyol/go-dcp v1.1.12/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
github.com/Trendyol/go-dcp v1.1.13 h1:g4Ku+I5Gx+jQcxaysdEE7bOZzRVbqfLxZBSQplPVjR4=
github.com/Trendyol/go-dcp v1.1.13/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
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
8 changes: 4 additions & 4 deletions kafka/metadata/kafka_metadata.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -135,14 +135,14 @@ func (s *kafkaMetadata) Clear(_ []uint16) error {

func NewKafkaMetadata(
kafkaClient gKafka.Client,
kafkaMetadataConfig map[string]any,
kafkaMetadataConfig map[string]string,
) metadata.Metadata {
var topic string
var partition int
var replicationFactor int

if _, ok := kafkaMetadataConfig["topic"]; ok {
topic = kafkaMetadataConfig["topic"].(string)
topic = kafkaMetadataConfig["topic"]
} else {
panic(errors.New("topic is not defined"))
}
Expand All @@ -152,7 +152,7 @@ func NewKafkaMetadata(
}

if _, ok := kafkaMetadataConfig["partition"]; ok {
partition, _ = strconv.Atoi(kafkaMetadataConfig["partition"].(string))
partition, _ = strconv.Atoi(kafkaMetadataConfig["partition"])
} else {
partition = 25
}
Expand All @@ -162,7 +162,7 @@ func NewKafkaMetadata(
}

if _, ok := kafkaMetadataConfig["replicationFactor"]; ok {
replicationFactor, _ = strconv.Atoi(kafkaMetadataConfig["replicationFactor"].(string))
replicationFactor, _ = strconv.Atoi(kafkaMetadataConfig["replicationFactor"])
} else {
replicationFactor = 3
}
Expand Down
2 changes: 1 addition & 1 deletion test/integration/go.mod
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ go 1.19
replace github.com/Trendyol/go-dcp-kafka => ../../.

require (
github.com/Trendyol/go-dcp v1.1.12
github.com/Trendyol/go-dcp v1.1.13
github.com/Trendyol/go-dcp-kafka v1.0.3
github.com/segmentio/kafka-go v0.4.42
)
Expand Down
4 changes: 2 additions & 2 deletions test/integration/go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@ dario.cat/mergo v1.0.0 h1:AGCNq9Evsj31mOgNPcLyXc+4PNABt905YmuqPYYpBWk=
github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 h1:UQHMgLO+TxOElx5B5HZ4hJQsoJ/PvUvKRhJHDQXO8P8=
github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow=
github.com/Microsoft/hcsshim v0.11.1 h1:hJ3s7GbWlGK4YVV92sO88BQSyF4ZLVy7/awqOlPxFbA=
github.com/Trendyol/go-dcp v1.1.12 h1:eRdP4W2k9wt3KcoszGrGCJD31uYXdUlWApf77g9uFzg=
github.com/Trendyol/go-dcp v1.1.12/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
github.com/Trendyol/go-dcp v1.1.13 h1:g4Ku+I5Gx+jQcxaysdEE7bOZzRVbqfLxZBSQplPVjR4=
github.com/Trendyol/go-dcp v1.1.13/go.mod h1:epMDitjzGJw9lQOUYWjBSQ8drs/4WGu6Ct3BRkeXQAM=
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 test/integration/integration_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ func TestKafka(t *testing.T) {
},
Metadata: dcpConfig.Metadata{
ReadOnly: true,
Config: map[string]any{
Config: map[string]string{
"bucket": "dcp-test",
"scope": "_default",
"collection": "_default",
Expand Down

0 comments on commit ec651c9

Please sign in to comment.