Kafka transport

[matzew]

based on PR cloudevents/spec#337, we could introduce a kafka module here, that helps to encode/decode the CloudEvent class over Kafka, using Headers for the attributes, and using the key/value of the message for the CloudEvents data

We did already do some prototype a couple of month ago:

https://github.com/rh-event-flow/jcloudevents/blob/master/kafka/src/main/java/io/streamzi/cloudevents/kafka/util/KafkaHeaderUtil.java#L42

[matzew]

API Proposal

Implement some util, containg method for:

• extracting cloudevent from a ConsumerRecord
• Creating RecordHeaders from a a Cloudevent, and wrap that to the Kafka message

Below is some pseudo code that could be part of the "API" util:

public ProducerRecord createProducerRecord(final CloudEvent<?> e);

public ConsumerRecord createConsomerRecord(final CloudEvent<?> e);

public Headers extractRecordHeaders(final CloudEvent<?> ce);

public <K, V> CloudEvent<Map<K, V>> fromConsumerRecord(final ConsumerRecord<K, V>);
public <K, V> CloudEvent<Map<K, V>> fromProducerRecord(final ProducerRecord<K, V> record);

[fabiojose]

Done the PR #49

Let's close this?

[matzew]

/close

…

On Wed, Sep 25, 2019 at 8:26 PM Fabio José ***@***.***> wrote: Done the PR #49 <#49> Let's close this? — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#5?email_source=notifications&email_token=AABGPTQ7QEMJQVHHD757TM3QLOUNZA5CNFSM4GCJTQ5KYY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGOD7S4E5A#issuecomment-535151220>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AABGPTRVNRE6X3EF5HEZF4TQLOUNZANCNFSM4GCJTQ5A> .

-- Matthias Wessendorf github: https://github.com/matzew twitter: http://twitter.com/mwessendorf

[fabiojose]

This is the docs about Kafka Transport Binding: https://github.com/cloudevents/sdk-java/blob/master/kafka/README.md