feat: add new hook to automatically generate kafka schemas

Author: yannrouillard

.pre-commit-hooks.yaml

@@ -34,3 +34,11 @@
     stages: [commit]
     always_run: true
     pass_filenames: false
+
+-   id: kafka-check-schemas
+    name: Check if local Kafka Schemas are up to date with code
+    language: script
+    entry: ./kafka-check-local-schemas.sh
+    stages: [commit]
+    always_run: true
+    pass_filenames: false

kafka-check-local-schemas.sh

@@ -0,0 +1,31 @@
+#!/usr/bin/env bash
+
+# Safety measures
+set -o errexit  # Leave immediately if a command returns an error
+set -o nounset  # Leave immediately if an unitialized value is used
+set -o pipefail # Leave immediately if a command fails in a pipe
+
+[[ "${BASH_VERSION}" =~ ^(5|4\.[0-9]).* ]] && shopt -s inherit_errexit
+
+#####################################################################
+# Helper functions
+#####################################################################
+
+function error() {
+    local msg="$1" exit_code="${2:-}"
+    echo "ERROR: ${msg}">&2
+    exit "${exit_code}"
+}
+
+function check_binary_exists() {
+    local binary="$1"
+  command -v "${binary}" &>/dev/null || error "${binary} is required but it's not installed"
+}
+
+#####################################################################
+# Main code
+#####################################################################
+
+check_binary_exists "sbt"
+
+sbt "runMain tools.generateSchemaFile schemas/schema.json"