Adding timer in onJoinPrepare

[xiaoyali97]

backport fix to 7.2.x #2363

[xiaoyali97]

Build fails on downstream validation, doesn't seems related to this PR.

18:16:31  Found the following MAVEN files have been modified:
18:16:31  pom.xml
18:16:31  Committing changes made to all of the MAVEN files.
18:16:31  ['git', 'diff', '--no-color', 'pom.xml'] @ /home/jenkins/workspace/_builder_schema-registry_PR-2381/kafka-connect-databricks-delta-lake-master
18:16:31  Traceback (most recent call last):
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/bin/ci-update-version", line 8, in <module>
18:16:31      sys.exit(update_version())
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/click/core.py", line 1130, in __call__
18:16:31      return self.main(*args, **kwargs)
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/click/core.py", line 1055, in main
18:16:31      rv = self.invoke(ctx)
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/click/core.py", line 1404, in invoke
18:16:31      return ctx.invoke(self.callback, **ctx.params)
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/click/core.py", line 760, in invoke
18:16:31      return __callback(*args, **kwargs)
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/confluent/ci/scripts/update_version.py", line 88, in update_version
18:16:31      updater.main()
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/confluent/ci/scripts/update_version.py", line 202, in main
18:16:31      self.commit_changed()
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/confluent/ci/scripts/update_version.py", line 265, in commit_changed
18:16:31      self.commit_files()
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/confluent/ci/scripts/update_version.py", line 569, in commit_files
18:16:31      run_cmd(cmd, self.repo_path)
18:16:31    File "/home/jenkins/workspace/_builder_schema-registry_PR-2381@tmp/ci-tools/lib/python3.9/site-packages/confluent/ci/scripts/ci_utils.py", line 41, in run_cmd
18:16:31      stdout, _ = proc.communicate()
18:16:31    File "/usr/local/lib/python3.9/subprocess.py", line 1121, in communicate
18:16:31      stdout = self.stdout.read()
18:16:31    File "/usr/local/lib/python3.9/codecs.py", line 322, in decode
18:16:31      (result, consumed) = self._buffer_decode(data, self.errors, final)
18:16:31  UnicodeDecodeError: 'utf-8' codec can't decode byte 0xae in position 427: invalid start byte
[Pipeline] echo
18:16:31  downstream validation failed on kafka-connect-databricks-delta-lake

[csghuser]

@xiaoyali97

We've upgraded to 7.2.2-ccs from 7.2.1-ccs this morning. We're now seeing the following in our logs when trying to start the schema-registry.

[2022-11-01 08:58:49,514] ERROR Unexpected exception in schema registry group processing thread (io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector)
java.lang.AbstractMethodError: Receiver class io.confluent.kafka.schemaregistry.leaderelector.kafka.SchemaRegistryCoordinator does not define or inherit an implementation of the resolved method 'abstract boolean onJoinPrepare(org.apache.kafka.common.utils.Timer, int, java.lang.String)' of abstract class org.apache.kafka.clients.consumer.internals.AbstractCoordinator.
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:443)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:385)
        at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:365)
        at io.confluent.kafka.schemaregistry.leaderelector.kafka.SchemaRegistryCoordinator.poll(SchemaRegistryCoordinator.java:113)
        at io.confluent.kafka.schemaregistry.leaderelector.kafka.KafkaGroupLeaderElector$1.run(KafkaGroupLeaderElector.java:199)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:829)

In this case there are 2 existing schema-registries which are up and running (version 7.2.1). We are trying to deploy 7.2.2 as part of a rolling restart, and so we're trying to bring up a third schema-registry running 7.2.2.

Any idea why we might be seeing this?

EDIT: Solved.... was a result of having mixed package versions installed:

confluent-rest-utils-7.2.2-1.noarch
confluent-common-7.2.2-1.noarch
confluent-schema-registry-7.2.1-1.noarch

Once all were 7.2.2 it's fine.