MINOR: Fix DefaultRecordBatch and DefaultRecord protocol documentation (

#17196)

Reviewers: Chia-Ping Tsai <[email protected]>

clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java

@@ -41,10 +41,15 @@
  *   Attributes => Int8
  *   TimestampDelta => Varlong
  *   OffsetDelta => Varint
+ *   KeyLength => Varint
  *   Key => Bytes
+ *   ValueLength => Varint
  *   Value => Bytes
+ *   HeadersCount => Varint
  *   Headers => [HeaderKey HeaderValue]
+ *     HeaderKeyLength => Varint
  *     HeaderKey => String
+ *     HeaderValueLength => Varint
  *     HeaderValue => Bytes
  *
  * Note that in this schema, the Bytes and String types use a variable length integer to represent

clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java

@@ -57,6 +57,7 @@
  *  ProducerId => Int64
  *  ProducerEpoch => Int16
  *  BaseSequence => Int32
+ *  RecordsCount => Int32
  *  Records => [Record]
  *
  * Note that when compression is enabled (see attributes below), the compressed record data is serialized

docs/implementation.html

@@ -55,6 +55,7 @@ <h4 class="anchor-heading"><a id="recordbatch" class="anchor-link"></a><a href="
 producerId: int64
 producerEpoch: int16
 baseSequence: int32
+recordsCount: int32
 records: [Record]</code></pre>
     <p> Note that when compression is enabled, the compressed record data is serialized directly following the count of the number of records. </p>
 
@@ -88,8 +89,9 @@ <h4 class="anchor-heading"><a id="record" class="anchor-link"></a><a href="#reco
 offsetDelta: varint
 keyLength: varint
 key: byte[]
-valueLen: varint
+valueLength: varint
 value: byte[]
+headersCount: varint
 Headers => [Header]</code></pre>
 	<h5 class="anchor-heading"><a id="recordheader" class="anchor-link"></a><a href="#recordheader">5.3.2.1 Record Header</a></h5>
 	<pre><code class="language-text">headerKeyLength: varint