disable kafka temp

apache · Jan 27, 2025 · 146ed44 · 146ed44
1 parent 052570a
commit 146ed44
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 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")
+    set(DISABLED_TAGS "SKIP_CI,NEEDS_NUMPY,ENABLE_KAFKA")
 
     add_custom_target(
             docker-verify-${TAG_PREFIX}

diff --git a/docker/test/integration/features/google_cloud_storage.feature b/docker/test/integration/features/google_cloud_storage.feature
@@ -28,6 +28,7 @@ Feature: Sending data to Google Cloud Storage using PutGCSObject
     And a PutFile processor with the "Directory" property set to "/tmp/output"
     And the "success" relationship of the GetFile processor is connected to the PutGCSObject
     And the "success" relationship of the PutGCSObject processor is connected to the PutFile
+    And the "failure" relationship of the PutGCSObject processor is connected to the PutGCSObject
 
     When all instances start up
 

diff --git a/docker/test/integration/features/steps/steps.py b/docker/test/integration/features/steps/steps.py
@@ -737,7 +737,7 @@ def step_impl(context, content, topic_name):
         "ssl.key.location": client_key_file.name,
         "client.id": socket.gethostname()})
     producer.produce(topic_name, content.encode("utf-8"), callback=delivery_report)
-    producer.flush(50)
+    producer.flush(10)
 
 
 # Used for testing transactional message consumption