Merge pull request #206 from JacobSMoller/timestamp-type-bit

Record TimestampType functionality match comment
twmb · Oct 6, 2022 · d3e35a4 · d3e35a4
2 parents 65375ff + 8566354
commit d3e35a4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/kgo/record_and_fetch.go b/pkg/kgo/record_and_fetch.go
@@ -44,7 +44,7 @@ func (a RecordAttrs) TimestampType() int8 {
 	if a.attrs&0b1000_0000 != 0 {
 		return -1
 	}
-	return int8(a.attrs & 0b0000_1000)
+	return int8(a.attrs&0b0000_1000) >> 3
 }
 
 // CompressionType signifies with which algorithm this record was compressed.