martinzink commented on code in PR #2044:
URL: https://github.com/apache/nifi-minifi-cpp/pull/2044#discussion_r2495269825
##########
extensions/kafka/tests/features/steps/steps.py:
##########
@@ -0,0 +1,85 @@
+import binascii
+
+from behave import step, when, given
+
+
+from minifi_test_framework.steps import checking_steps # noqa: F401
+from minifi_test_framework.steps import configuration_steps # noqa: F401
+from minifi_test_framework.steps import core_steps # noqa: F401
+from minifi_test_framework.steps import flow_building_steps # noqa: F401
+from minifi_test_framework.core.minifi_test_context import MinifiTestContext
+from minifi_test_framework.minifi.processor import Processor
+from kafka_server_container import KafkaServer
+
+
+@step("a {processor_name} processor set up to communicate with an Azure blob
storage")
+def step_impl(context: MinifiTestContext, processor_name: str):
+ processor = Processor(processor_name, processor_name)
+ hostname = f"http://azure-storage-server-{context.scenario_id}"
+ processor.add_property('Container Name', 'test-container')
+ processor.add_property('Connection String',
'DefaultEndpointsProtocol=http;AccountName=devstoreaccount1;AccountKey=Eby8vdM02xNOcqFlqUwJPLlmEtlCDXJ1OUzFT50uSRZ6IFsuFq2UVErCz4I6tq/K1SZFPTOtr/KBHBeksoGMGw==;BlobEndpoint={hostname}:10000/devstoreaccount1;QueueEndpoint={hostname}:10001/devstoreaccount1;'.format(hostname=hostname))
+ processor.add_property('Blob', 'test-blob')
+ processor.add_property('Create Container', 'true')
+ context.minifi_container.flow_definition.add_processor(processor)
Review Comment:
yeah and not just that this modular kafka part is not close to being ready
(it wasnt run thats why i didnt notice) i reverted the kafka to the legacy
framework and removed this modular part 👍
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]