diff --git a/describeconfigs.go b/describeconfigs.go index 4f5c09514..17f4f305f 100644 --- a/describeconfigs.go +++ b/describeconfigs.go @@ -14,7 +14,7 @@ type DescribeConfigsRequest struct { // Address of the kafka broker to send the request to. Addr net.Addr - // List of resources to update. + // List of resources to get details for. Resources []DescribeConfigRequestResource // Ignored if API version is less than v1 diff --git a/writer.go b/writer.go index dc9c77f78..f3c6bd4d1 100644 --- a/writer.go +++ b/writer.go @@ -307,10 +307,6 @@ type WriterConfig struct { // a response to a produce request. The default is -1, which means to wait for // all replicas, and a value above 0 is required to indicate how many replicas // should acknowledge a message to be considered successful. - // - // This version of kafka-go (v0.3) does not support 0 required acks, due to - // some internal complexity implementing this with the Kafka protocol. If you - // need that functionality specifically, you'll need to upgrade to v0.4. RequiredAcks int // Setting this flag to true causes the WriteMessages method to never block.