Xdydy opened a new issue, #54: URL: https://github.com/apache/rocketmq-eventbridge/issues/54
I have a task which is asked that when I produce the message to rocketmq, it can transform the message to aliyun eventbridge or aliyun function-compute. However, this failed even when I try the demo about /putEvents ```text 2023-02-07 10:37:10.083@@@@@@@@[reactor-http-server-epoll-10]@@INFO@@accessLog[62]@@requestTraceId : | url : http://127.0.0.1:7001/putEvents | requestParam : {} | requestMethod : POST | requestBody : "{\n \"specversion\": \"1.0\",\n \"type\": \"rocketmq\",\n \"source\": \"https://github.com/cloudevents/spec/pull\",\n \"subject\": \"123\",\n \"id\": \"A234-1234-1234\",\n \"time\": \"2018-04-05T17:31:00Z\",\n \"datacontenttype\": \"application/json\",\n \"data\": {\n \"body\": \"demo\"\n },\n \"aliyuneventbusname\": \"demo-bus\"\n}" 2023-02-07 10:37:10.093@@@@@@@@[reactor-http-server-epoll-10]@@ERROR@@accessLog[64]@@Catch unexpected exception. java.util.NoSuchElementException: No value present at java.util.Optional.get(Optional.java:135) at org.apache.rocketmq.eventbridge.adapter.api.converter.EventConverterAdapter.getEventConverter(EventConverterAdapter.java:74) at org.apache.rocketmq.eventbridge.adapter.api.converter.EventConverterAdapter.toEventsRequest(EventConverterAdapter.java:61) at org.apache.rocketmq.eventbridge.adapter.api.controller.EventDataController.lambda$putEvents$0(EventDataController.java:62) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:118) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:1637) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:103) at reactor.core.publisher.MonoCurrentContext.subscribe(MonoCurrentContext.java:33) at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60) at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74) at reactor.core.publisher.FluxSourceMonoFuseable.subscribe(FluxSourceMonoFuseable.java:38) at reactor.core.publisher.FluxMapFuseable.subscribe(FluxMapFuseable.java:63) at org.springframework.http.server.reactive.ChannelSendOperator.subscribe(ChannelSendOperator.java:74) at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1080) at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:198) at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:198) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1080) at reactor.core.publisher.MonoIgnoreThen$ThenAcceptInner.onNext(MonoIgnoreThen.java:290) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1080) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1080) at reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:241) at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:323) at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:185) at reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:92) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:115) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:115) at reactor.core.publisher.FluxFilterFuseable$FilterFuseableSubscriber.onNext(FluxFilterFuseable.java:104) at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1080) at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:117) at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:245) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:130) at reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:245) at reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:130) at reactor.ipc.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:377) at reactor.ipc.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:202) at reactor.ipc.netty.channel.FluxReceive.request(FluxReceive.java:110) at reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:149) at reactor.core.publisher.FluxPeek$PeekSubscriber.request(FluxPeek.java:130) at reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:149) at reactor.core.publisher.FluxPeek$PeekSubscriber.request(FluxPeek.java:130) at reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onSubscribe(MonoCollectList.java:90) at reactor.core.publisher.FluxPeek$PeekSubscriber.onSubscribe(FluxPeek.java:163) at reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:86) at reactor.core.publisher.FluxPeek$PeekSubscriber.onSubscribe(FluxPeek.java:163) at reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:86) at reactor.ipc.netty.channel.FluxReceive.startReceiver(FluxReceive.java:273) at reactor.ipc.netty.channel.FluxReceive.subscribe(FluxReceive.java:124) at reactor.core.publisher.FluxMap.subscribe(FluxMap.java:62) at reactor.ipc.netty.ByteBufFlux.subscribe(ByteBufFlux.java:242) at reactor.core.publisher.FluxPeek.subscribe(FluxPeek.java:83) at reactor.ipc.netty.ByteBufFlux.subscribe(ByteBufFlux.java:242) at reactor.core.publisher.FluxMap.subscribe(FluxMap.java:62) at reactor.core.publisher.FluxPeek.subscribe(FluxPeek.java:83) at reactor.core.publisher.MonoCollectList.subscribe(MonoCollectList.java:59) at reactor.core.publisher.MonoFilterFuseable.subscribe(MonoFilterFuseable.java:47) at reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59) at reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59) at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44) at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44) at reactor.core.publisher.MonoDefaultIfEmpty.subscribe(MonoDefaultIfEmpty.java:37) at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71) at reactor.core.publisher.Mono.subscribe(Mono.java:3080) at reactor.core.publisher.MonoZip.subscribe(MonoZip.java:128) at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:148) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56) at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74) at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74) at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44) at reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150) at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67) at reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:271) at reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:803) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:115) at reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:1637) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:156) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:1451) at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:1325) at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:90) at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54) at reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59) at reactor.core.publisher.Mono.subscribe(Mono.java:3080) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:418) at reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:210) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:128) at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:61) at reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121) at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40) at reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44) at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60) at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoSubscriberContext.subscribe(MonoSubscriberContext.java:47) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52) at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44) at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44) at reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44) at reactor.core.publisher.Mono.subscribe(Mono.java:3080) at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:167) at reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56) at reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70) at reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61) at reactor.ipc.netty.channel.ChannelOperations.applyHandler(ChannelOperations.java:380) at reactor.ipc.netty.http.server.HttpServerOperations.onHandlerStart(HttpServerOperations.java:397) at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:163) at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404) at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:309) at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:884) at java.lang.Thread.run(Thread.java:748) ``` -- 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]
