fix: consumer func #5
Annotations
10 errors
sonarcloud:
client.go#L117
error returned from external package is unwrapped: sig: func (github.com/twmb/franz-go/pkg/kgo.ProduceResults).FirstErr() error (wrapcheck)
|
sonarcloud:
codec.go#L8
error returned from external package is unwrapped: sig: func encoding/json.Marshal(v any) ([]byte, error) (wrapcheck)
|
sonarcloud:
codec.go#L11
Decode returns interface (T) (ireturn)
|
sonarcloud:
codec.go#L15
error returned from external package is unwrapped: sig: func encoding/json.Unmarshal(data []byte, v any) error (wrapcheck)
|
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)
|
sonarcloud:
example/admin/main.go#L45
error returned from external package is unwrapped: sig: func (*github.com/twmb/franz-go/pkg/kadm.Client).ListTopics(ctx context.Context, topics ...string) (github.com/twmb/franz-go/pkg/kadm.TopicDetails, error) (wrapcheck)
|
sonarcloud:
example/consume/main.go#L39
error returned from external package is unwrapped: sig: func encoding/json.Unmarshal(data []byte, v any) error (wrapcheck)
|
sonarcloud:
example/consume/main.go#L52
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/produce/main.go#L46
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)
|