Initial version using the RabbitMQ Stream java client. Various hotfixes to get serialization as expected by Apache Flink.
Adding Cloud Event support. Expecting JSON-encoded cloud events in the message payload. Includes support for filtering by event type.
Support for the AMQP Protocol binding. Cloudevent Properties are then part of AMQP application-properties.
Has the benefit, that filtering for certain event types can be handled before the message payload has to be deserialized.
Includes support for additional filtering by additional cloud event properties (source, subject)