Skip to content

Commit

Permalink
[receiver/kafka] fix lint for kafka receiver (#12789)
Browse files Browse the repository at this point in the history
  • Loading branch information
fatsheep9146 authored Aug 3, 2022
1 parent 979e0c1 commit f92920f
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions receiver/kafkareceiver/kafka_receiver_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
// See the License for the specific language governing permissions and
// limitations under the License.

// nolint:errcheck
package kafkareceiver

import (
Expand Down Expand Up @@ -678,7 +677,7 @@ var _ sarama.ConsumerGroup = (*testConsumerGroup)(nil)

func (t *testConsumerGroup) Consume(_ context.Context, _ []string, handler sarama.ConsumerGroupHandler) error {
t.once.Do(func() {
handler.Setup(testConsumerGroupSession{})
_ = handler.Setup(testConsumerGroupSession{})
})
return t.err
}
Expand Down

0 comments on commit f92920f

Please sign in to comment.