disable kafka temp

Author: martinzink

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}

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
 

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