Skip to content

Commit

Permalink
feature: fix golang ci errors
Browse files Browse the repository at this point in the history
  • Loading branch information
mhmtszr committed Dec 2, 2023
1 parent 8c9b7bb commit 986f527
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions otel_reader_wrapper.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,14 +26,14 @@ package kafka
// }, nil
//}
//
//func (o *otelReaderWrapper) FetchMessage(ctx context.Context) (*segmentio.Message, error) {
// func (o *otelReaderWrapper) FetchMessage(ctx context.Context) (*segmentio.Message, error) {
// return o.r.FetchMessage(ctx)
//}
//
//func (o *otelReaderWrapper) Close() error {
// func (o *otelReaderWrapper) Close() error {
// return o.r.Close()
//}
//
//func (o *otelReaderWrapper) CommitMessages(messages []segmentio.Message) error {
// func (o *otelReaderWrapper) CommitMessages(messages []segmentio.Message) error {
// return o.r.CommitMessages(context.Background(), messages...)
//}

0 comments on commit 986f527

Please sign in to comment.