diff --git a/generate/DEFINITIONS b/generate/DEFINITIONS index d8994d81..ec5b29c5 100644 --- a/generate/DEFINITIONS +++ b/generate/DEFINITIONS @@ -594,7 +594,7 @@ ListOffsetsRequest => key 2, max version 5 // // The initial leader epoch can be determined from a MetadataResponse. // To skip log truncation checking, use -1. - CurrentLeaderEpoch: int32 // v4+ + CurrentLeaderEpoch: int32(-1) // v4+ // Timestamp controls which offset to return in a response for this // partition. // @@ -677,7 +677,7 @@ ListOffsetsResponse => Offset: int64(-1) // v1+ // LeaderEpoch is the leader epoch of the record at this offset, // or -1 if there was no leader epoch. - LeaderEpoch: int32 // v4+ + LeaderEpoch: int32(-1) // v4+ // MetadataRequest requests metadata from Kafka. MetadataRequest => key 3, max version 9, flexible v9+ diff --git a/pkg/kmsg/generated.go b/pkg/kmsg/generated.go index bbddeb5e..93f841c4 100644 --- a/pkg/kmsg/generated.go +++ b/pkg/kmsg/generated.go @@ -2283,6 +2283,7 @@ type ListOffsetsRequestTopicPartition struct { } func (v *ListOffsetsRequestTopicPartition) Default() { + v.CurrentLeaderEpoch = -1 } type ListOffsetsRequestTopic struct { @@ -2518,6 +2519,7 @@ type ListOffsetsResponseTopicPartition struct { func (v *ListOffsetsResponseTopicPartition) Default() { v.Timestamp = -1 v.Offset = -1 + v.LeaderEpoch = -1 } type ListOffsetsResponseTopic struct {