@@ -61,8 +61,8 @@ linters:
- structcheck
# - stylecheck
- typecheck
- # - unconvert
- # - unused
+ - unconvert
+ - unused
# - varcheck
- whitespace
# - goconst
@@ -53,7 +53,7 @@ func (d *DeleteAclsResponse) key() int16 {
}
func (d *DeleteAclsResponse) version() int16 {
- return int16(d.Version)
+ return d.Version
func (d *DeleteAclsResponse) requiredVersion() KafkaVersion {
@@ -74,7 +74,7 @@ func (d *DescribeAclsResponse) key() int16 {
func (d *DescribeAclsResponse) version() int16 {
func (d *DescribeAclsResponse) requiredVersion() KafkaVersion {
@@ -667,7 +667,7 @@ func (mr *MockDeleteTopicsResponse) For(reqBody versionedDecoder) encoder {
for _, topic := range req.Topics {
res.TopicErrorCodes[topic] = ErrNoError
- res.Version = int16(req.Version)
+ res.Version = req.Version
return res
@@ -6,7 +6,7 @@ type offsetRequestBlock struct {
func (b *offsetRequestBlock) encode(pe packetEncoder, version int16) error {
- pe.putInt64(int64(b.time))
+ pe.putInt64(b.time)
if version == 0 {
pe.putInt32(b.maxOffsets)