RobertIndie opened a new issue, #1867:
URL: https://github.com/apache/streampipes/issues/1867
### Apache StreamPipes version
dev (current development state)
### Affected StreamPipes components
Processing Elements
### What happened?
If the adapter couldn't connect to the pulsar, It will still show that it
was created successfully. Even though there is a connecting exception thrown in
the log.
Here is the log:
```
2023-09-04T12:42:04.669Z WARN 1 --- [-client-io-10-1]
o.a.pulsar.client.impl.ConnectionPool : Failed to open connection to
localhost/<unresolved>:6650 :
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused: localhost/127.0.0.1:6650
2023-09-04T12:42:04.670Z WARN 1 --- [-client-io-10-1]
o.a.pulsar.client.impl.PulsarClientImpl :
[org.apache.streampipes.connect.39b5125e-eeba-4cc7-a519-b8852fa4033e] Failed to
get partitioned topic metadata:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused: localhost/127.0.0.1:6650
org.apache.streampipes.commons.exceptions.SpRuntimeException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.ExecutionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650{"previous":[{"attempt":0,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":1,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) fail
ed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":2,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":3,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":4,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused: localhost/127.0.0.1:6650"},{
"attempt":5,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":6,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":7,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":8,"error":"java.util.concurrent.Completion
Exception: org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"}]}{"previous":[{"attempt":0,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":1,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":2,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.ap
i.PulsarClientException: java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":3,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":4,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":5,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.Comple
tionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":6,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":7,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
finishConnect(..) failed: Connection refused:
localhost/127.0.0.1:6650"},{"attempt":8,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.chan
nel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed:
Connection refused: localhost/127.0.0.1:6650"}]}
at
org.apache.streampipes.messaging.pulsar.PulsarProducer.connect(PulsarProducer.java:51)
at
org.apache.streampipes.extensions.management.connect.adapter.preprocessing.elements.SendToBrokerAdapterSink.<init>(SendToBrokerAdapterSink.java:64)
at
org.apache.streampipes.extensions.management.connect.adapter.preprocessing.elements.SendToPulsarAdapterSink.<init>(SendToPulsarAdapterSink.java:31)
at
org.apache.streampipes.extensions.management.connect.adapter.AdapterPipelineGenerator.getAdapterSink(AdapterPipelineGenerator.java:82)
at
org.apache.streampipes.extensions.management.connect.adapter.AdapterPipelineGenerator.generatePipeline(AdapterPipelineGenerator.java:64)
at
org.apache.streampipes.extensions.management.connect.adapter.model.EventCollector.from(EventCollector.java:36)
at
org.apache.streampipes.extensions.management.connect.AdapterWorkerManagement.invokeAdapter(AdapterWorkerManagement.java:68)
at
org.apache.streampipes.rest.extensions.connect.AdapterWorkerResource.invokeAdapter(AdapterWorkerResource.java:78)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown
Source)
at java.base/java.lang.reflect.Method.invoke(Unknown Source)
... ...
2023-09-04T12:42:04.674Z INFO 1 --- [ XNIO-1 task-3]
o.a.s.r.e.connect.AdapterWorkerResource : Stream adapter with id
sp:adapterdescription:NXOpCd successfully started
```
### How to reproduce?
_No response_
### Expected behavior
_No response_
### Additional technical information
_No response_
### Are you willing to submit a PR?
None
--
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]
