fix: batch consumer #8
rytshAnnotations
11 errors
|
sonarcloud
Process completed with exit code 1.
|
|
sonarcloud:
client.go#L123
error returned from external package is unwrapped: sig: func (github.com/twmb/franz-go/pkg/kgo.ProduceResults).FirstErr() error (wrapcheck)
|
|
sonarcloud:
codec.go#L10
Comment should end in a period (godot)
|
|
sonarcloud:
codec.go#L52
error returned from external package is unwrapped: sig: func encoding/json.Marshal(v any) ([]byte, error) (wrapcheck)
|
|
sonarcloud:
codec.go#L55
Decode returns interface (T) (ireturn)
|
|
sonarcloud:
codec.go#L59
error returned from external package is unwrapped: sig: func encoding/json.Unmarshal(data []byte, v any) error (wrapcheck)
|
|
sonarcloud:
consumerbatch.go#L68
`if c.DecodeWithRecord != nil` has complex nested blocks (complexity: 7) (nestif)
|
|
sonarcloud:
consumersingle.go#L54
unused-parameter: parameter 'ctx' seems to be unused, consider removing or renaming it as _ (revive)
|
|
sonarcloud:
consumersingle.go#L91
`if c.DecodeWithRecord != nil` has complex nested blocks (complexity: 7) (nestif)
|
|
sonarcloud:
example/admin/main.go#L25
error returned from external package is unwrapped: sig: func github.com/worldline-go/wkafka.NewClient(cfg github.com/worldline-go/wkafka.Config, opts ...github.com/worldline-go/wkafka.Option) (*github.com/worldline-go/wkafka.Client, error) (wrapcheck)
|
|
sonarcloud:
example/admin/main.go#L33
error returned from external package is unwrapped: sig: func (*github.com/twmb/franz-go/pkg/kadm.Client).CreateTopic(ctx context.Context, partitions int32, replicationFactor int16, configs map[string]*string, topic string) (github.com/twmb/franz-go/pkg/kadm.CreateTopicResponse, error) (wrapcheck)
|