Small fixes

client.go

@@ -370,9 +370,8 @@ func (client *Client) update(data *MetadataResponse) ([]string, error) {
 // Creates a new ClientConfig instance with sensible defaults
 func NewClientConfig() *ClientConfig {
 	return &ClientConfig{
-		MetadataRetries:      3,
+		MetadataRetries: 3,
-		WaitForElection:      250 * time.Millisecond,
+		WaitForElection: 250 * time.Millisecond,
-		ConcurrencyPerBroker: 0,
 	}
 }
 

consumer.go

@@ -320,6 +320,7 @@ func (c *Consumer) getOffset(where OffsetTime, retry bool) (int64, error) {
 	return -1, block.Err
 }
 
+// Creates a ConsumerConfig instance with sane defaults.
 func NewConsumerConfig() *ConsumerConfig {
 	return &ConsumerConfig{
 		DefaultFetchSize: 1024,
@@ -328,10 +329,8 @@ func NewConsumerConfig() *ConsumerConfig {
 	}
 }
 
-// Validates a ConsumerConfig instance. This will change zero
+// Validates a ConsumerConfig instance. It will return a
-// values into sensible defaults if possible, and it will return a
+// ConfigurationError if the specified value doesn't make sense.
-// ConfigurationError if the specified value doesn't make sense and
-// cannot be corrected.
 func (config *ConsumerConfig) Validate() error {
 	if config.DefaultFetchSize <= 0 {
 		return ConfigurationError("Invalid DefaultFetchSize")

producer.go

@@ -456,7 +456,7 @@ func NewProducerConfig() *ProducerConfig {
 	}
 }
 
-// Validates a ProducerConfig instance. t will return a
+// Validates a ProducerConfig instance. It will return a
 // ConfigurationError if the specified value doesn't make sense.
 func (config *ProducerConfig) Validate() error {
 	if config.RequiredAcks < -1 {