diff --git a/poetry.lock b/poetry.lock
index 8700907..b3bccf2 100644
--- a/poetry.lock
+++ b/poetry.lock
@@ -1,4 +1,4 @@
-# This file is automatically @generated by Poetry 1.8.3 and should not be changed by hand.
+# This file is automatically @generated by Poetry 1.8.2 and should not be changed by hand.
 
 [[package]]
 name = "aarc-entitlement"
@@ -616,8 +616,8 @@ uvicorn = "^0.22.0"
 [package.source]
 type = "git"
 url = "https://github.com/infn-datacloud/federation-registry.git"
-reference = "v1.0.0-beta.1"
-resolved_reference = "a37dc8e4e09ec7def7c066ac47f3b6aba24a1859"
+reference = "v1.0.0-beta.2"
+resolved_reference = "d9fcc046bb1ff34f1ddca3dc29aeb0447121cc03"
 
 [[package]]
 name = "filelock"
@@ -2369,4 +2369,4 @@ test = ["big-O", "jaraco.functools", "jaraco.itertools", "jaraco.test", "more-it
 [metadata]
 lock-version = "2.0"
 python-versions = ">=3.9,<4.0.0"
-content-hash = "150cd575c57878bfc2c07ee01aec68efe9798debd9bf6c24cc9ce0584f84ad3f"
+content-hash = "0b7c28396a5af4821d01efc30a59b1e4f8343a251ef13e94bde36d8fe6b4991b"
diff --git a/pyproject.toml b/pyproject.toml
index 0a27318..331da14 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -9,7 +9,7 @@ packages = [{ include = "src" }]
 python = ">=3.9,<4.0.0"
 python-openstackclient = "^6.2.0"
 python-glanceclient = "^4.4.0"
-federation-registry = {git = "https://github.com/infn-datacloud/federation-registry.git", tag = "v1.0.0-beta.1"}
+federation-registry = {git = "https://github.com/infn-datacloud/federation-registry.git", tag = "v1.0.0-beta.2"}
 liboidcagent = "^0.6" # {git = "https://github.com/giosava94/liboidc-agent-py.git", branch = "local-and-remote" }
 kafka-python = "^2.0.2"
 
diff --git a/tests/test_kafka.py b/tests/test_kafka.py
index dfbc586..524ed99 100644
--- a/tests/test_kafka.py
+++ b/tests/test_kafka.py
@@ -1,4 +1,3 @@
-import json
 from logging import getLogger
 from unittest.mock import Mock, patch
 
@@ -165,20 +164,18 @@ def test_send_messages(
     send_kafka_messages(kafka_prod=mock_prod, connections_data=[{**connection_data}])
 
     mock_prod.send.assert_called_with(
-        json.dumps(
-            {
-                "msg_version": "1.0.0",
-                "provider_name": connection_data["provider_conf"]["name"],
-                "provider_type": connection_data["provider_conf"]["type"],
-                "region_name": connection_data["provider_conf"]["regions"][0]["name"],
-                "issuer_endpoint": connection_data["issuer"]["endpoint"],
-                "user_group": connection_data["issuer"]["user_groups"][0]["name"],
-                "project_id": connection_data["project"]["uuid"],
-                "block_storage_services": connection_data["block_storage_services"],
-                "compute_services": connection_data["compute_services"],
-                "identity_services": connection_data["identity_services"],
-                "network_services": connection_data["network_services"],
-                "object_store_services": connection_data["object_store_services"],
-            }
-        )
+        {
+            "msg_version": "1.0.0",
+            "provider_name": connection_data["provider_conf"]["name"],
+            "provider_type": connection_data["provider_conf"]["type"],
+            "region_name": connection_data["provider_conf"]["regions"][0]["name"],
+            "issuer_endpoint": connection_data["issuer"]["endpoint"],
+            "user_group": connection_data["issuer"]["user_groups"][0]["name"],
+            "project_id": connection_data["project"]["uuid"],
+            "block_storage_services": connection_data["block_storage_services"],
+            "compute_services": connection_data["compute_services"],
+            "identity_services": connection_data["identity_services"],
+            "network_services": connection_data["network_services"],
+            "object_store_services": connection_data["object_store_services"],
+        }
     )