From b649bde45cf73cc575e48520d0e7f94c001371a1 Mon Sep 17 00:00:00 2001 From: LeonHartley Date: Tue, 24 Sep 2024 19:42:55 +0000 Subject: [PATCH] Update OffsetCommit CommittedLeaderEpoch to v6, fixes #1334 --- protocol/offsetcommit/offsetcommit.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/protocol/offsetcommit/offsetcommit.go b/protocol/offsetcommit/offsetcommit.go index 5844928a6..cbde5ae89 100644 --- a/protocol/offsetcommit/offsetcommit.go +++ b/protocol/offsetcommit/offsetcommit.go @@ -28,7 +28,7 @@ type RequestPartition struct { PartitionIndex int32 `kafka:"min=v0,max=v7"` CommittedOffset int64 `kafka:"min=v0,max=v7"` CommitTimestamp int64 `kafka:"min=v1,max=v1"` - CommittedLeaderEpoch int32 `kafka:"min=v5,max=v7"` + CommittedLeaderEpoch int32 `kafka:"min=v6,max=v7"` CommittedMetadata string `kafka:"min=v0,max=v7,nullable"` }