Skip to content

Commit

Permalink
Fix lint failure: SA1019
Browse files Browse the repository at this point in the history
  • Loading branch information
Mongey committed Mar 13, 2024
1 parent 4953939 commit c5d189e
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions kafka/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -235,7 +235,6 @@ func (c *Client) UpdateTopic(topic Topic) error {
}

res, err := broker.AlterConfigs(r)

if err != nil {
return err
}
Expand Down Expand Up @@ -350,7 +349,6 @@ func (c *Client) buildAssignment(t Topic) (*[][]int32, error) {

allReplicas := c.allReplicas()
newRF := t.ReplicationFactor
rand.Seed(time.Now().UnixNano())

assignment := make([][]int32, len(partitions))
for _, p := range partitions {
Expand Down Expand Up @@ -587,6 +585,7 @@ func (c *Client) topicConfig(topic string) (map[string]*string, error) {
func (c *Client) getDescribeAclsRequestAPIVersion() int16 {
return int16(c.versionForKey(29, 1))
}

func (c *Client) getCreateAclsRequestAPIVersion() int16 {
return int16(c.versionForKey(30, 1))
}
Expand Down

0 comments on commit c5d189e

Please sign in to comment.