Skip to content

CloudEventMessageUtils.getSource fails on Kafka messages. #1190

@joachimm

Description

@joachimm

Describe the bug

CloudEventMessageUtils.getSource, fails on incoming Kafka message.

I am using cloud stream binder and the header 'ce_source' is of type byte[]
getSource expects String or URI.

Sample
CloudEventMessageUtils.getSource(MessageBuilder.withPayload(new Object()).setHeader("ce_source", new byte[] {}));

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions