feat(wip): support latest versions of kafka protocol

Author: id

.tool-versions

@@ -0,0 +1,3 @@
+scala 3.7.2
+gradle 9.0.0
+erlang 27.2-3

Makefile

@@ -12,7 +12,7 @@ GEN_CODE = src/kpro_schema.erl
 .PHONY: kafka-bnf
 kafka-bnf:
 	@cd priv/kafka_protocol_bnf && gradle run
-	@cat priv/kafka.bnf | grep "#.*ApiKey" | awk '{print "{"$$2" "$$3"}."}' | sed -r 's/([A-Z])/_\L\1/g' | sed 's/{_/{/' | sort -hk2 > priv/api-keys.eterm
+	@python3 priv/process_api_keys.py
 
 $(GEN_CODE): $(GEN_INPUT)
 	@priv/kpro_gen.escript

priv/api-keys.eterm

@@ -41,3 +41,33 @@
 {alter_partition_reassignments, 45}.
 {list_partition_reassignments, 46}.
 {offset_delete, 47}.
+{describe_client_quotas, 48}.
+{alter_client_quotas, 49}.
+{describe_user_scram_credentials, 50}.
+{alter_user_scram_credentials, 51}.
+{fetch_snapshot, 59}.
+{describe_cluster, 60}.
+{describe_producers, 61}.
+{unregister_broker, 64}.
+{describe_transactions, 65}.
+{list_transactions, 66}.
+{consumer_group_heartbeat, 68}.
+{consumer_group_describe, 69}.
+{controller_registration, 70}.
+{get_telemetry_subscriptions, 71}.
+{push_telemetry, 72}.
+{assign_replicas_to_dirs, 73}.
+{list_config_resources, 74}.
+{describe_topic_partitions, 75}.
+{share_group_heartbeat, 76}.
+{share_group_describe, 77}.
+{share_fetch, 78}.
+{share_acknowledge, 79}.
+{add_raft_voter, 80}.
+{remove_raft_voter, 81}.
+{update_raft_voter, 82}.
+{streams_group_heartbeat, 88}.
+{streams_group_describe, 89}.
+{describe_share_group_offsets, 90}.
+{alter_share_group_offsets, 91}.
+{delete_share_group_offsets, 92}.