diff --git a/src/bruce/kafka_proto/v0/wire_proto.cc b/src/bruce/kafka_proto/v0/wire_proto.cc index bc4cce4..edcf0e4 100644 --- a/src/bruce/kafka_proto/v0/wire_proto.cc +++ b/src/bruce/kafka_proto/v0/wire_proto.cc @@ -112,6 +112,10 @@ TWireProto::ProcessAck(int16_t ack_value, const std::string &topic, int32_t partition) const { assert(this); + /* The errors reported below are documented here: + + https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ErrorCodes + */ switch (static_cast(ack_value)) { case TErrorCode::Unknown: { AckErrorUnknown.Increment();