diff --git a/kafka/client.go b/kafka/client.go index a7affbdf..47ef6cb7 100644 --- a/kafka/client.go +++ b/kafka/client.go @@ -235,7 +235,6 @@ func (c *Client) UpdateTopic(topic Topic) error { } res, err := broker.AlterConfigs(r) - if err != nil { return err } @@ -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 { @@ -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)) }