From d27fa9c2fb012cf60d3e4e45141ca059889c6cf7 Mon Sep 17 00:00:00 2001 From: Robert Yokota Date: Sun, 31 Jul 2022 22:05:03 -0700 Subject: [PATCH] Upgrade to Kafka 3.2.1 --- .../main/java/io/kareldb/server/leader/KarelDbCoordinator.java | 2 +- pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/kareldb-server/src/main/java/io/kareldb/server/leader/KarelDbCoordinator.java b/kareldb-server/src/main/java/io/kareldb/server/leader/KarelDbCoordinator.java index b988dc43..91fee600 100644 --- a/kareldb-server/src/main/java/io/kareldb/server/leader/KarelDbCoordinator.java +++ b/kareldb-server/src/main/java/io/kareldb/server/leader/KarelDbCoordinator.java @@ -208,7 +208,7 @@ protected Map onLeaderElected( } @Override - protected boolean onJoinPrepare(int generation, String memberId) { + protected boolean onJoinPrepare(Timer timer, int generation, String memberId) { LOG.debug("Revoking previous assignment {}", assignmentSnapshot); if (assignmentSnapshot != null) { listener.onRevoked(); diff --git a/pom.xml b/pom.xml index 8af8e947..1ef12e9d 100644 --- a/pom.xml +++ b/pom.xml @@ -67,7 +67,7 @@ limitations under the License. 9.4.42.v20210604 4.12 2.13 - 3.2.0 + 3.2.1 4.0.4 3.3.0 3.1.0