From d195342eabbd8938659725a84c205cc7f84b04d8 Mon Sep 17 00:00:00 2001 From: Eric Bowden Date: Fri, 1 May 2026 10:27:52 -0500 Subject: [PATCH] Fix wrong decoder used for leadershipTermId in EgressAdapter NewLeader path --- src/Adaptive.Cluster/Client/EgressAdapter.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Adaptive.Cluster/Client/EgressAdapter.cs b/src/Adaptive.Cluster/Client/EgressAdapter.cs index e751fc81..779bb524 100644 --- a/src/Adaptive.Cluster/Client/EgressAdapter.cs +++ b/src/Adaptive.Cluster/Client/EgressAdapter.cs @@ -158,7 +158,7 @@ public void OnFragment(IDirectBuffer buffer, int offset, int length, Header head { _listener.OnNewLeader( sessionId, - _sessionEventDecoder.LeadershipTermId(), + _newLeaderEventDecoder.LeadershipTermId(), _newLeaderEventDecoder.LeaderMemberId(), _newLeaderEventDecoder.IngressEndpoints()); }