Confluent kafka avro (#35932) (#35961)

* Added avro extra package for data serialization * Reverted global poetry.lock Co-authored-by: Jorge Candedo <[email protected]>
demisto · Feb 2, 2025 · bf5d5f7 · bf5d5f7
1 parent 75c8dc8
commit bf5d5f7
Show file tree

Hide file tree

Showing 3 changed files with 77 additions and 9 deletions.
diff --git a/docker/vendors-sdk/poetry.lock b/docker/vendors-sdk/poetry.lock
diff --git a/docker/vendors-sdk/pyproject.toml b/docker/vendors-sdk/pyproject.toml
@@ -8,7 +8,7 @@ readme = "README.md"
 [tool.poetry.dependencies]
 python = "~3.12"
 cloakensdk = "*"
-confluent-kafka = "==1.7.0" # need specific version of os package, see CIAC-8412
+confluent-kafka = {extras = ["avro"], version = "==1.7.0"} # need specific version of os package, see CIAC-8412
 fp-ngfw-smc-python = "*"
 pydantic = ">=2.5.3"
 duo-client = "*"

diff --git a/docker/vendors-sdk/verify.py b/docker/vendors-sdk/verify.py
@@ -5,6 +5,9 @@
 import cloakensdk.utility
 
 import confluent_kafka
+from confluent_kafka import Producer
+from confluent_kafka.schema_registry import SchemaRegistryClient
+from confluent_kafka.schema_registry.avro import AvroSerializer
 import smc
 import pydantic
 
@@ -15,4 +18,4 @@
 import jbxapi
 import cyberintegrations
 
-print('Verify of vendors-sdk image passed!')
+print('Verify of vendors-sdk image passed!')