You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@eventmesh.apache.org by GitBox <gi...@apache.org> on 2022/09/22 06:50:23 UTC
[GitHub] [incubator-eventmesh] fengyongshe opened a new issue, #1365: [Bug] Fix " Unknown connector runtime exception." in pulsar connector when publishing cloudevents
fengyongshe opened a new issue, #1365:
URL: https://github.com/apache/incubator-eventmesh/issues/1365
### Search before asking
- [X] I had searched in the [issues](https://github.com/apache/eventmesh/issues?q=is%3Aissue) and found no similar issues.
### Environment
Mac
### EventMesh version
master
### What happened
Publish CloudEvents to pulsar connector, fails with exeception
```
org.apache.eventmesh.api.exception.ConnectorRuntimeException: Unknown connector runtime exception.
at org.apache.eventmesh.connector.pulsar.producer.AbstractProducer.checkProducerException(AbstractProducer.java:48) ~[?:?]
at org.apache.eventmesh.connector.pulsar.producer.ProducerImpl.publish(ProducerImpl.java:63) ~[?:?]
at org.apache.eventmesh.connector.pulsar.producer.PulsarProducerImpl.publish(PulsarProducerImpl.java:44) ~[?:?]
at org.apache.eventmesh.runtime.core.plugin.MQProducerWrapper.send(MQProducerWrapper.java:81) ~[eventmesh-runtime-1.6.0-release.jar:1.6.0-release]
at org.apache.eventmesh.runtime.core.protocol.grpc.producer.EventMeshProducer.send(EventMeshProducer.java:46) ~[eventmesh-runtime-1.6.0-release.jar:1.6.0-release]
......
```
Causes:
EventMeshExentension only load the dependency jar from ${eventmesh_home}/lib. But Producer in pulsar connector use ProtobufFormat ,
```
byte[] serializedCloudEvent = EventFormatProvider
.getInstance()
.resolveFormat(ProtobufFormat.PROTO_CONTENT_TYPE)
.serialize(cloudEvent);
```
this is no cloudevents-protobuf-xx.jar in lib dir。
Resolution：
Add the cloudevents-protobuf dependency in the root build.gradle or use the jsonFormat as same as other connectors
### How to reproduce
1）Enable pulsar connector by setting connector.plugin.type=pulsar
2) Send CloudEvent by JAVA SDK
3) See the eventmesh runtime log, there will be ConnectionRuntimeException
4) Put the cloudevents-protobuf-xx.jar in the lib dir, can resolve the exception
### Debug logs
_No response_
### Are you willing to submit PR?
- [ ] Yes I am willing to submit a PR!
--
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: dev-unsubscribe@eventmesh.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org
[GitHub] [incubator-eventmesh] xwm1992 closed issue #1365: [Bug] Unknown connector runtime exception in pulsar connector when publishing cloudevents
Posted by GitBox <gi...@apache.org>.
xwm1992 closed issue #1365: [Bug] Unknown connector runtime exception in pulsar connector when publishing cloudevents
URL: https://github.com/apache/incubator-eventmesh/issues/1365
--
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: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org
[GitHub] [incubator-eventmesh] fengyongshe commented on issue #1365: [Bug] Unknown connector runtime exception in pulsar connector when publishing cloudevents
Posted by GitBox <gi...@apache.org>.
fengyongshe commented on issue #1365:
URL: https://github.com/apache/incubator-eventmesh/issues/1365#issuecomment-1254704774
please assign it to me.
--
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: dev-unsubscribe@eventmesh.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: dev-help@eventmesh.apache.org