diff --git a/changelog.md b/changelog.md index 6af47e7..ce1b072 100644 --- a/changelog.md +++ b/changelog.md @@ -4,6 +4,12 @@ All notable changes to this project will be documented in this file. This project adheres to Semantic Versioning. +## 2.0.3 (Nov 22, 2024) + +1. Updated `go.uber.org/mock` version `0.5.0` +2. Updated `golang.org/x/sync` version `0.9.0` +3. Removed noisy log `Timed out on read` + ## 2.0.2 (Nov 18, 2024) 1. Updated `confluent-kafka-go` version `2.6.1` along with other dependencies diff --git a/example/producer_avro/go.mod b/example/producer_avro/go.mod index 6502a9e..229e2a0 100644 --- a/example/producer_avro/go.mod +++ b/example/producer_avro/go.mod @@ -11,10 +11,10 @@ require ( github.com/bahlo/generic-list-go v0.2.0 // indirect github.com/bufbuild/protocompile v0.8.0 // indirect github.com/buger/jsonparser v1.1.1 // indirect - github.com/confluentinc/confluent-kafka-go/v2 v2.5.3 // indirect + github.com/confluentinc/confluent-kafka-go/v2 v2.6.1 // indirect github.com/golang/protobuf v1.5.4 // indirect github.com/google/uuid v1.6.0 // indirect - github.com/hamba/avro/v2 v2.24.0 // indirect + github.com/hamba/avro/v2 v2.27.0 // indirect github.com/heetch/avro v0.4.5 // indirect github.com/invopop/jsonschema v0.12.0 // indirect github.com/jhump/protoreflect v1.15.6 // indirect @@ -31,6 +31,6 @@ require ( go.opentelemetry.io/otel/trace v1.30.0 // indirect golang.org/x/sync v0.8.0 // indirect google.golang.org/genproto v0.0.0-20240325203815-454cdb8f5daa // indirect - google.golang.org/protobuf v1.34.2 // indirect + google.golang.org/protobuf v1.35.2 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/example/producer_avro/go.sum b/example/producer_avro/go.sum index 4e01f23..3ed21bd 100644 --- a/example/producer_avro/go.sum +++ b/example/producer_avro/go.sum @@ -83,6 +83,7 @@ github.com/compose-spec/compose-go/v2 v2.1.0 h1:qdW2qISQlCQG8v1O2TChcdxgAWTUGgUX github.com/compose-spec/compose-go/v2 v2.1.0/go.mod h1:bEPizBkIojlQ20pi2vNluBa58tevvj0Y18oUSHPyfdc= github.com/confluentinc/confluent-kafka-go/v2 v2.5.3 h1:3AAMHvhiv3d4ajW4fSnZw+liipffhtunkEWz23zTXXM= github.com/confluentinc/confluent-kafka-go/v2 v2.5.3/go.mod h1:QxYLPRKR1MVlkXCCjzjjrpXb0VyFNfVaZXi0obZykJ0= +github.com/confluentinc/confluent-kafka-go/v2 v2.6.1/go.mod h1:hScqtFIGUI1wqHIgM3mjoqEou4VweGGGX7dMpcUKves= github.com/containerd/console v1.0.4 h1:F2g4+oChYvBTsASRTz8NP6iIAi97J3TtSAsLbIFn4ro= github.com/containerd/console v1.0.4/go.mod h1:YynlIjWYF8myEu6sdkwKIvGQq+cOckRm6So2avqoYAk= github.com/containerd/containerd v1.7.15 h1:afEHXdil9iAm03BmhjzKyXnnEBtjaLJefdU7DV0IFes= @@ -160,8 +161,6 @@ github.com/golang-jwt/jwt/v5 v5.2.0 h1:d/ix8ftRUorsN+5eMIlF4T6J8CAt9rch3My2winC1 github.com/golang-jwt/jwt/v5 v5.2.0/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk= github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE= github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= -go.uber.org/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc= -go.uber.org/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs= github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM= @@ -195,6 +194,7 @@ github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0 h1:YBftPWNWd4WwGqtY2yeZL2ef8rH github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0/go.mod h1:YN5jB8ie0yfIUg6VvR9Kz84aCaG7AsGZnLjhHbUqwPg= github.com/hamba/avro/v2 v2.24.0 h1:axTlaYDkcSY0dVekRSy8cdrsj5MG86WqosUQacKCids= github.com/hamba/avro/v2 v2.24.0/go.mod h1:7vDfy/2+kYCE8WUHoj2et59GTv0ap7ptktMXu0QHePI= +github.com/hamba/avro/v2 v2.27.0/go.mod h1:jN209lopfllfrz7IGoZErlDz+AyUJ3vrBePQFZwYf5I= github.com/hashicorp/errwrap v1.1.0 h1:OxrOeh75EUXMY8TBjag2fzXGZ40LB6IKw45YeGUDY2I= github.com/hashicorp/errwrap v1.1.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4= github.com/hashicorp/go-cleanhttp v0.5.2 h1:035FKYIWjmULyFRBKPs8TBQoi0x6d9G4xc9neXJWAZQ= @@ -440,6 +440,8 @@ go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lI go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM= go.uber.org/mock v0.4.0 h1:VcM4ZOtdbR4f6VXfiOpwpVJDL6lCReaZ6mw31wqh7KU= go.uber.org/mock v0.4.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc= +go.uber.org/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc= +go.uber.org/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs= golang.org/x/crypto v0.22.0 h1:g1v0xeRhjcugydODzvb3mEM9SQ0HGp9s/nh3COQ/C30= golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M= golang.org/x/exp v0.0.0-20240112132812-db7319d0e0e3 h1:hNQpMuAJe5CtcUqCXaWga3FHu+kQvCqcsoVaQgSV60o= @@ -472,6 +474,7 @@ google.golang.org/grpc v1.62.1 h1:B4n+nfKzOICUXMgyrNd19h/I9oH0L1pizfk1d4zSgTk= google.golang.org/grpc v1.62.1/go.mod h1:IWTG0VlJLCh1SkC58F7np9ka9mx/WNkjl4PGJaiq+QE= google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg= google.golang.org/protobuf v1.34.2/go.mod h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw= +google.golang.org/protobuf v1.35.2/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE= gopkg.in/cenkalti/backoff.v1 v1.1.0 h1:Arh75ttbsvlpVA7WtVpH4u9h6Zl46xuptxqLxPiSo4Y= gopkg.in/cenkalti/backoff.v1 v1.1.0/go.mod h1:J6Vskwqd+OMVJl8C33mmtxTBs2gyzfv7UDAkHu8BrjI= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= diff --git a/example/worker_avro/go.mod b/example/worker_avro/go.mod index eeea674..c52e929 100644 --- a/example/worker_avro/go.mod +++ b/example/worker_avro/go.mod @@ -14,9 +14,9 @@ require ( github.com/bahlo/generic-list-go v0.2.0 // indirect github.com/bufbuild/protocompile v0.8.0 // indirect github.com/buger/jsonparser v1.1.1 // indirect - github.com/confluentinc/confluent-kafka-go/v2 v2.5.3 // indirect + github.com/confluentinc/confluent-kafka-go/v2 v2.6.1 // indirect github.com/golang/protobuf v1.5.4 // indirect - github.com/hamba/avro/v2 v2.24.0 // indirect + github.com/hamba/avro/v2 v2.27.0 // indirect github.com/heetch/avro v0.4.5 // indirect github.com/invopop/jsonschema v0.12.0 // indirect github.com/jhump/protoreflect v1.15.6 // indirect @@ -33,6 +33,6 @@ require ( go.opentelemetry.io/otel/trace v1.30.0 // indirect golang.org/x/sync v0.8.0 // indirect google.golang.org/genproto v0.0.0-20240325203815-454cdb8f5daa // indirect - google.golang.org/protobuf v1.34.2 // indirect + google.golang.org/protobuf v1.35.2 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/example/worker_avro/go.sum b/example/worker_avro/go.sum index 4e01f23..3ed21bd 100644 --- a/example/worker_avro/go.sum +++ b/example/worker_avro/go.sum @@ -83,6 +83,7 @@ github.com/compose-spec/compose-go/v2 v2.1.0 h1:qdW2qISQlCQG8v1O2TChcdxgAWTUGgUX github.com/compose-spec/compose-go/v2 v2.1.0/go.mod h1:bEPizBkIojlQ20pi2vNluBa58tevvj0Y18oUSHPyfdc= github.com/confluentinc/confluent-kafka-go/v2 v2.5.3 h1:3AAMHvhiv3d4ajW4fSnZw+liipffhtunkEWz23zTXXM= github.com/confluentinc/confluent-kafka-go/v2 v2.5.3/go.mod h1:QxYLPRKR1MVlkXCCjzjjrpXb0VyFNfVaZXi0obZykJ0= +github.com/confluentinc/confluent-kafka-go/v2 v2.6.1/go.mod h1:hScqtFIGUI1wqHIgM3mjoqEou4VweGGGX7dMpcUKves= github.com/containerd/console v1.0.4 h1:F2g4+oChYvBTsASRTz8NP6iIAi97J3TtSAsLbIFn4ro= github.com/containerd/console v1.0.4/go.mod h1:YynlIjWYF8myEu6sdkwKIvGQq+cOckRm6So2avqoYAk= github.com/containerd/containerd v1.7.15 h1:afEHXdil9iAm03BmhjzKyXnnEBtjaLJefdU7DV0IFes= @@ -160,8 +161,6 @@ github.com/golang-jwt/jwt/v5 v5.2.0 h1:d/ix8ftRUorsN+5eMIlF4T6J8CAt9rch3My2winC1 github.com/golang-jwt/jwt/v5 v5.2.0/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk= github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE= github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= -go.uber.org/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc= -go.uber.org/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs= github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM= @@ -195,6 +194,7 @@ github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0 h1:YBftPWNWd4WwGqtY2yeZL2ef8rH github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0/go.mod h1:YN5jB8ie0yfIUg6VvR9Kz84aCaG7AsGZnLjhHbUqwPg= github.com/hamba/avro/v2 v2.24.0 h1:axTlaYDkcSY0dVekRSy8cdrsj5MG86WqosUQacKCids= github.com/hamba/avro/v2 v2.24.0/go.mod h1:7vDfy/2+kYCE8WUHoj2et59GTv0ap7ptktMXu0QHePI= +github.com/hamba/avro/v2 v2.27.0/go.mod h1:jN209lopfllfrz7IGoZErlDz+AyUJ3vrBePQFZwYf5I= github.com/hashicorp/errwrap v1.1.0 h1:OxrOeh75EUXMY8TBjag2fzXGZ40LB6IKw45YeGUDY2I= github.com/hashicorp/errwrap v1.1.0/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4= github.com/hashicorp/go-cleanhttp v0.5.2 h1:035FKYIWjmULyFRBKPs8TBQoi0x6d9G4xc9neXJWAZQ= @@ -440,6 +440,8 @@ go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lI go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM= go.uber.org/mock v0.4.0 h1:VcM4ZOtdbR4f6VXfiOpwpVJDL6lCReaZ6mw31wqh7KU= go.uber.org/mock v0.4.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc= +go.uber.org/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc= +go.uber.org/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs= golang.org/x/crypto v0.22.0 h1:g1v0xeRhjcugydODzvb3mEM9SQ0HGp9s/nh3COQ/C30= golang.org/x/crypto v0.22.0/go.mod h1:vr6Su+7cTlO45qkww3VDJlzDn0ctJvRgYbC2NvXHt+M= golang.org/x/exp v0.0.0-20240112132812-db7319d0e0e3 h1:hNQpMuAJe5CtcUqCXaWga3FHu+kQvCqcsoVaQgSV60o= @@ -472,6 +474,7 @@ google.golang.org/grpc v1.62.1 h1:B4n+nfKzOICUXMgyrNd19h/I9oH0L1pizfk1d4zSgTk= google.golang.org/grpc v1.62.1/go.mod h1:IWTG0VlJLCh1SkC58F7np9ka9mx/WNkjl4PGJaiq+QE= google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg= google.golang.org/protobuf v1.34.2/go.mod h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw= +google.golang.org/protobuf v1.35.2/go.mod h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE= gopkg.in/cenkalti/backoff.v1 v1.1.0 h1:Arh75ttbsvlpVA7WtVpH4u9h6Zl46xuptxqLxPiSo4Y= gopkg.in/cenkalti/backoff.v1 v1.1.0/go.mod h1:J6Vskwqd+OMVJl8C33mmtxTBs2gyzfv7UDAkHu8BrjI= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= diff --git a/go.mod b/go.mod index b7147b4..4f2fe91 100644 --- a/go.mod +++ b/go.mod @@ -13,8 +13,8 @@ require ( github.com/zillow/zfmt v1.0.1 go.opentelemetry.io/otel v1.30.0 go.opentelemetry.io/otel/trace v1.30.0 - go.uber.org/mock v0.4.0 - golang.org/x/sync v0.8.0 + go.uber.org/mock v0.5.0 + golang.org/x/sync v0.9.0 google.golang.org/protobuf v1.35.2 ) diff --git a/go.sum b/go.sum index 88e9e4f..45fd625 100644 --- a/go.sum +++ b/go.sum @@ -433,8 +433,8 @@ go.opentelemetry.io/otel/trace v1.30.0 h1:7UBkkYzeg3C7kQX8VAidWh2biiQbtAKjyIML8d go.opentelemetry.io/otel/trace v1.30.0/go.mod h1:5EyKqTzzmyqB9bwtCCq6pDLktPK6fmGf/Dph+8VI02o= go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lIVU/I= go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM= -go.uber.org/mock v0.4.0 h1:VcM4ZOtdbR4f6VXfiOpwpVJDL6lCReaZ6mw31wqh7KU= -go.uber.org/mock v0.4.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc= +go.uber.org/mock v0.5.0 h1:KAMbZvZPyBPWgD14IrIQ38QCyjwpvVVV6K/bHl1IwQU= +go.uber.org/mock v0.5.0/go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM= golang.org/x/crypto v0.27.0 h1:GXm2NjJrPaiv/h1tb2UH8QfgC/hOf/+z0p6PT8o1w7A= golang.org/x/crypto v0.27.0/go.mod h1:1Xngt8kV6Dvbssa53Ziq6Eqn0HqbZi5Z6R0ZpwQzt70= golang.org/x/exp v0.0.0-20240112132812-db7319d0e0e3 h1:hNQpMuAJe5CtcUqCXaWga3FHu+kQvCqcsoVaQgSV60o= @@ -443,8 +443,8 @@ golang.org/x/net v0.29.0 h1:5ORfpBpCs4HzDYoodCDBbwHzdR5UrLBZ3sOnUJmFoHo= golang.org/x/net v0.29.0/go.mod h1:gLkgy8jTGERgjzMic6DS9+SP0ajcu6Xu3Orq/SpETg0= golang.org/x/oauth2 v0.18.0 h1:09qnuIAgzdx1XplqJvW6CQqMCtGZykZWcXzPMPUusvI= golang.org/x/oauth2 v0.18.0/go.mod h1:Wf7knwG0MPoWIMMBgFlEaSUDaKskp0dCfrlJRJXbBi8= -golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ= -golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sync v0.9.0 h1:fEo0HyrW1GIgZdpbhCRO0PkJajUS5H9IFUztCgEo2jQ= +golang.org/x/sync v0.9.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= golang.org/x/sys v0.25.0 h1:r+8e+loiHxRqhXVl6ML1nO3l1+oFoWbnlu2Ehimmi34= golang.org/x/sys v0.25.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/term v0.24.0 h1:Mh5cbb+Zk2hqqXNO7S1iTjEphVL+jb8ZWaqh/g+JWkM= diff --git a/mocks/confluent/kafka_consumer.go b/mocks/confluent/kafka_consumer.go index 24aa51f..7d1d452 100644 --- a/mocks/confluent/kafka_consumer.go +++ b/mocks/confluent/kafka_consumer.go @@ -21,6 +21,7 @@ import ( type MockKafkaConsumer struct { ctrl *gomock.Controller recorder *MockKafkaConsumerMockRecorder + isgomock struct{} } // MockKafkaConsumerMockRecorder is the mock recorder for MockKafkaConsumer. @@ -99,45 +100,45 @@ func (mr *MockKafkaConsumerMockRecorder) Commit() *gomock.Call { } // ReadMessage mocks base method. -func (m *MockKafkaConsumer) ReadMessage(arg0 time.Duration) (*kafka.Message, error) { +func (m *MockKafkaConsumer) ReadMessage(timeout time.Duration) (*kafka.Message, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "ReadMessage", arg0) + ret := m.ctrl.Call(m, "ReadMessage", timeout) ret0, _ := ret[0].(*kafka.Message) ret1, _ := ret[1].(error) return ret0, ret1 } // ReadMessage indicates an expected call of ReadMessage. -func (mr *MockKafkaConsumerMockRecorder) ReadMessage(arg0 any) *gomock.Call { +func (mr *MockKafkaConsumerMockRecorder) ReadMessage(timeout any) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ReadMessage", reflect.TypeOf((*MockKafkaConsumer)(nil).ReadMessage), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ReadMessage", reflect.TypeOf((*MockKafkaConsumer)(nil).ReadMessage), timeout) } // StoreOffsets mocks base method. -func (m *MockKafkaConsumer) StoreOffsets(arg0 []kafka.TopicPartition) ([]kafka.TopicPartition, error) { +func (m *MockKafkaConsumer) StoreOffsets(offsets []kafka.TopicPartition) ([]kafka.TopicPartition, error) { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "StoreOffsets", arg0) + ret := m.ctrl.Call(m, "StoreOffsets", offsets) ret0, _ := ret[0].([]kafka.TopicPartition) ret1, _ := ret[1].(error) return ret0, ret1 } // StoreOffsets indicates an expected call of StoreOffsets. -func (mr *MockKafkaConsumerMockRecorder) StoreOffsets(arg0 any) *gomock.Call { +func (mr *MockKafkaConsumerMockRecorder) StoreOffsets(offsets any) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StoreOffsets", reflect.TypeOf((*MockKafkaConsumer)(nil).StoreOffsets), arg0) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StoreOffsets", reflect.TypeOf((*MockKafkaConsumer)(nil).StoreOffsets), offsets) } // SubscribeTopics mocks base method. -func (m *MockKafkaConsumer) SubscribeTopics(arg0 []string, arg1 kafka.RebalanceCb) error { +func (m *MockKafkaConsumer) SubscribeTopics(topics []string, rebalanceCb kafka.RebalanceCb) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "SubscribeTopics", arg0, arg1) + ret := m.ctrl.Call(m, "SubscribeTopics", topics, rebalanceCb) ret0, _ := ret[0].(error) return ret0 } // SubscribeTopics indicates an expected call of SubscribeTopics. -func (mr *MockKafkaConsumerMockRecorder) SubscribeTopics(arg0, arg1 any) *gomock.Call { +func (mr *MockKafkaConsumerMockRecorder) SubscribeTopics(topics, rebalanceCb any) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SubscribeTopics", reflect.TypeOf((*MockKafkaConsumer)(nil).SubscribeTopics), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SubscribeTopics", reflect.TypeOf((*MockKafkaConsumer)(nil).SubscribeTopics), topics, rebalanceCb) } diff --git a/mocks/confluent/kafka_producer.go b/mocks/confluent/kafka_producer.go index bf2da87..b945f04 100644 --- a/mocks/confluent/kafka_producer.go +++ b/mocks/confluent/kafka_producer.go @@ -20,6 +20,7 @@ import ( type MockKafkaProducer struct { ctrl *gomock.Controller recorder *MockKafkaProducerMockRecorder + isgomock struct{} } // MockKafkaProducerMockRecorder is the mock recorder for MockKafkaProducer. @@ -52,15 +53,15 @@ func (mr *MockKafkaProducerMockRecorder) Close() *gomock.Call { } // Produce mocks base method. -func (m *MockKafkaProducer) Produce(arg0 *kafka.Message, arg1 chan kafka.Event) error { +func (m *MockKafkaProducer) Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error { m.ctrl.T.Helper() - ret := m.ctrl.Call(m, "Produce", arg0, arg1) + ret := m.ctrl.Call(m, "Produce", msg, deliveryChan) ret0, _ := ret[0].(error) return ret0 } // Produce indicates an expected call of Produce. -func (mr *MockKafkaProducerMockRecorder) Produce(arg0, arg1 any) *gomock.Call { +func (mr *MockKafkaProducerMockRecorder) Produce(msg, deliveryChan any) *gomock.Call { mr.mock.ctrl.T.Helper() - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Produce", reflect.TypeOf((*MockKafkaProducer)(nil).Produce), arg0, arg1) + return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Produce", reflect.TypeOf((*MockKafkaProducer)(nil).Produce), msg, deliveryChan) } diff --git a/mocks/mock_client.go b/mocks/mock_client.go index 4bc1f4b..b800471 100644 --- a/mocks/mock_client.go +++ b/mocks/mock_client.go @@ -21,6 +21,7 @@ import ( type MockClientProvider struct { ctrl *gomock.Controller recorder *MockClientProviderMockRecorder + isgomock struct{} } // MockClientProviderMockRecorder is the mock recorder for MockClientProvider. diff --git a/mocks/mock_logger.go b/mocks/mock_logger.go index c3946c9..d2fad61 100644 --- a/mocks/mock_logger.go +++ b/mocks/mock_logger.go @@ -20,6 +20,7 @@ import ( type MockLogger struct { ctrl *gomock.Controller recorder *MockLoggerMockRecorder + isgomock struct{} } // MockLoggerMockRecorder is the mock recorder for MockLogger. diff --git a/mocks/mock_reader.go b/mocks/mock_reader.go index 8f5885f..5d71f73 100644 --- a/mocks/mock_reader.go +++ b/mocks/mock_reader.go @@ -21,6 +21,7 @@ import ( type MockReader struct { ctrl *gomock.Controller recorder *MockReaderMockRecorder + isgomock struct{} } // MockReaderMockRecorder is the mock recorder for MockReader. diff --git a/mocks/mock_writer.go b/mocks/mock_writer.go index 7f3fd00..39503b7 100644 --- a/mocks/mock_writer.go +++ b/mocks/mock_writer.go @@ -21,6 +21,7 @@ import ( type MockWriter struct { ctrl *gomock.Controller recorder *MockWriterMockRecorder + isgomock struct{} } // MockWriterMockRecorder is the mock recorder for MockWriter. diff --git a/reader.go b/reader.go index 105f16a..b4dd1ee 100644 --- a/reader.go +++ b/reader.go @@ -120,7 +120,6 @@ func (r *KReader) Read(ctx context.Context) (*Message, error) { // timeouts occur (because the assigned partitions aren't being written to, lack of activity, etc.). We'll // log them for debugging purposes if v.Code() == kafka.ErrTimedOut { - r.logger.Debugw(ctx, "timed out on read", "topics", r.topicConfig.topics()) return nil, nil } if v.IsRetriable() {