gongqian edited a comment on issue #1851:
URL: https://github.com/apache/camel-quarkus/issues/1851#issuecomment-781030355
I encountered the same issue with pulsar component, it is a simple
project..with inbound config like the following
Inbound configuration in the application.yaml
`mp.messaging.incoming.pulasr-test.connector=smallrye-camel`
`mp.messaging.incoming.pulasr-test.endpoint-uri:
pulsar:persistent://default/poc-topic?subscriptionType=SHARED&subscriptionName=reactive`
Quarkus has the following warning
<code>
2021-02-17 22:42:53,976 INFO
[org.apa.cam.imp.eng.InternalRouteStartupManager] (Quarkus Main Thread) Route:
route7 started and consuming from:
reactive-streams://0C994938016BAD2-0000000000000002
2021-02-17 22:42:53,982 WARN [io.sma.rea.mes.provider] (Quarkus Main
Thread) SRMSG00207: Some components are not connected to either downstream
consumers or upstream producers:
- IncomingConnector{channel:'pulasr-test',
attribute:'mp.messaging.incoming.pulasr-test'} has no downstream
-
SubscriberMethod{method:'com.gm.devit.drp.pulsar.inbound.IncomingConsumer#consume',
incoming:'pulsar-test'} has no upstream
</code>
Quarkus is the latest 1.11.3.Final
=================================
when I put an message to pulsar queue.. It throws a similar error reported
<code>
2021-02-17 23:13:43,386 ERROR [org.apa.cam.pro.err.DefaultErrorHandler]
(pulsar-external-listener-3-1) Failed delivery for (MessageId:
0C994938016BAD2-0000000000000004 on ExchangeId:
0C994938016BAD2-0000000000000005). Exhausted after delivery attempt: 1 caught:
java.lang.IllegalStateException: The stream has no active subscriptions
Message History (complete message history is disabled)
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor
Elapsed (ms)
[route5 ] [route5 ]
[from[pulsar://persistent://default/poc-topic?subscription] [ 4]
...
[route5 ] [to7 ]
[reactive-streams:0C994938016BAD2-0000000000000000
] [ 0]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
: java.lang.IllegalStateException: The stream has no active subscriptions
at
org.apache.camel.component.reactive.streams.engine.CamelPublisher.publish(CamelPublisher.java:110)
at
org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService.sendCamelExchange(DefaultCamelReactiveStreamsService.java:151)
at
org.apache.camel.component.reactive.streams.ReactiveStreamsProducer.process(ReactiveStreamsProducer.java:52)
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:169)
at
org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:395)
at
org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
at
org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
at
org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
at
org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
at
org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
at
org.apache.camel.component.pulsar.PulsarMessageListener.process(PulsarMessageListener.java:64)
at
org.apache.camel.component.pulsar.PulsarMessageListener.received(PulsarMessageListener.java:53)
at
org.apache.pulsar.client.impl.ConsumerImpl.lambda$triggerListener$13(ConsumerImpl.java:1332)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:834)
</code>
----------------------------------------------------------------
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:
[email protected]
