nifi-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [nifi-minifi-cpp] szaszm commented on issue #697: MINIFICPP-1104 - SSL docker tests for PublishKafka
Date Wed, 15 Apr 2020 13:03:37 GMT
szaszm commented on issue #697: MINIFICPP-1104 - SSL docker tests for PublishKafka
URL: https://github.com/apache/nifi-minifi-cpp/pull/697#issuecomment-614026684
 
 
   I get multiple warnings like these:
   ```
   INFO     root:__init__.py:160 [2020-04-15 11:21:49.775] [org::apache::nifi::minifi::processors::GetFile]
[warning] Resolved missing Input Directory property value
   INFO     root:__init__.py:160 [2020-04-15 11:21:14.030] [org::apache::nifi::minifi::processors::PutFile]
[warning] Destination file /tmp/output/success/e5ca5a1c-8029-4036-985f-990c3cdb32c1 exists;
applying Conflict Resolution Strategy: fail
   
   [2020-04-15 11:21:51,302] WARN [Consumer clientId=consumer-1, groupId=console-consumer-25847]
Error connecting to node kafka-broker:9093 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient)
   java.io.IOException: Can't resolve address: kafka-broker:9093
   at org.apache.kafka.common.network.Selector.doConnect(Selector.java:235)
   at org.apache.kafka.common.network.Selector.connect(Selector.java:214)
   at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:864)
   at org.apache.kafka.clients.NetworkClient.access$700(NetworkClient.java:64)
   at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:1035)
   at org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater.maybeUpdate(NetworkClient.java:920)
   at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:508)
   at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:271)
   at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242)
   at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
   at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:161)
   at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:243)
   at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:314)
   at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
   at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181)
   at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)
   at kafka.tools.ConsoleConsumer$ConsumerWrapper.receive(ConsoleConsumer.scala:431)
   at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:103)
   at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:75)
   at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:53)
   at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
   Caused by: java.nio.channels.UnresolvedAddressException
   at sun.nio.ch.Net.checkAddress(Net.java:101)
   at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622)
   at org.apache.kafka.common.network.Selector.doConnect(Selector.java:233)
   ... 20 more
   ```
   
   result:
   ```
   FAILED ../docker/test/integration/test_rdkafka.py::test_broker_on_off - requests.exceptions.ReadTimeout:
UnixHTTPConnectionPool(host='localhost', port=None): Read timed out. (read timeout=60)
   
   _______________________________________________________________________________________________________________________________________________________________________________
test_ssl ________________________________________________________________________________________________________________________________________________________________________________
   
   def test_ssl():
   """
   Verify security connection
   """
   producer_flow = GetFile('/tmp/input') >> PublishKafkaSSL() \
   >> (('failure', LogAttribute()),
   ('success', PutFile('/tmp/output/ssl')))
   
   with DockerTestCluster(SingleFileOutputValidator('test')) as cluster:
   cluster.put_test_data('test')
   >           cluster.deploy_flow(None, engine='kafka-broker')
   
   ../docker/test/integration/test_rdkafka.py:89:
   _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _
   ../docker/test/integration/minifi/test/__init__.py:98: in deploy_flow
   engine=engine)
   ../docker/test/integration/minifi/__init__.py:105: in deploy_flow
   self.deploy_kafka_broker(name)
   ../docker/test/integration/minifi/__init__.py:211: in deploy_kafka_broker
   broker_image = self.build_image_by_path(test_dir + "/resources/kafka_broker", 'minifi-kafka')
   ../docker/test/integration/minifi/__init__.py:298: in build_image_by_path
   raise e
   ../docker/test/integration/minifi/__init__.py:292: in build_image_by_path
   forcerm=True)
   _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _
   [...]
   FAILED ../docker/test/integration/test_rdkafka.py::test_ssl - docker.errors.BuildError:
failed to get destination image "sha256:bdcd5fa7c1260b77c1e267ebbacdeef0bd6224492ce288d2d67fd20198894516":
No such image: sha256:bdcd5fa7c1260b77c1e267ebbacdeef0bd6224492ce288d2d67fd20198894516
   ```

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message