Fix kafka

apache · Jan 28, 2025 · 90cfc56 · 90cfc56
1 parent ca28a98
commit 90cfc56
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/cmake/VerifyPackageWithDocker.cmake b/cmake/VerifyPackageWithDocker.cmake
@@ -28,7 +28,7 @@ function(ADD_PACKAGE_VERIFY TAG_PREFIX)
         endif()
     endforeach()
 
-    set(DISABLED_TAGS "SKIP_CI,NEEDS_NUMPY,ENABLE_KAFKA")
+    set(DISABLED_TAGS "SKIP_CI,NEEDS_NUMPY")
 
     add_custom_target(
             docker-verify-${TAG_PREFIX}

diff --git a/docker/test/integration/features/steps/steps.py b/docker/test/integration/features/steps/steps.py
@@ -731,11 +731,13 @@ def step_impl(context, content, topic_name):
 
     producer = Producer({
         "bootstrap.servers": "localhost:29093",
-        "security.protocol": "ssl",
+        "security.protocol": "SSL",
         "ssl.ca.location": ca_cert_file.name,
         "ssl.certificate.location": client_cert_file.name,
         "ssl.key.location": client_key_file.name,
-        "client.id": socket.gethostname()})
+        "ssl.key.password": "",
+        "client.id": socket.gethostname(),
+        "ssl.endpoint.identification.algorithm": "none"})
     producer.produce(topic_name, content.encode("utf-8"), callback=delivery_report)
     producer.flush(10)