Cannot Push Kafka → EventMesh → HTTP Webhook (CloudEvents) despite correct config #5212
Description
Search before asking
- I had searched in the issues and found no similar issues.
Question
Hi team,
We are trying to use EventMesh as a Kafka → HTTP push gateway using CloudEvents in EKS and are stuck even after coup days of troubleshooting.
Kafka (Confluent Platform – KRaft mode)
↓
EventMesh Runtime (storage-plugin: kafka, protocol: cloudevents)
↓
HTTP Consumer (Python server expecting POST events)
What works
EventMesh HTTP publish API:
POST /eventmesh/publish/demo-user
→ HTTP consumer receives the event correctly.
EventMesh logs repeatedly show:
Value Deserializers with error: io.cloudevents.kafka.CloudEventDeserializer
Even after switching to:
eventMesh.protocol.type=cloudevents
eventMesh.server.kafka.deserializer.type=cloudevents
eventMesh.server.kafka.value.deserializer=io.cloudevents.kafka.CloudEventDeserializer
EventMesh logs repeatedly show:
Value Deserializers with error: io.cloudevents.kafka.CloudEventDeserializer
Even after switching to:
eventMesh.protocol.type=cloudevents
eventMesh.server.kafka.deserializer.type=cloudevents
eventMesh.server.kafka.value.deserializer=io.cloudevents.kafka.CloudEventDeserializer
We need help determining:
Is the CloudEventDeserializer actually supported in runtime with Kafka storage?
Is binary-mode CloudEvents supported for Kafka → HTTP push?
Any working example of:
Kafka producer (CloudEvents)
EventMesh CloudEvents protocol
Kafka → EventMesh → Webhook push config
I can share logs, configs, YAML, and producer code if needed.
Thanks for your support