based on PR <a class="issue-link js-issue-link" data-error-text="Failed to load title"

Done the PR <a class="issue-link js-issue-link" data-error-text="Failed to load title"

This is the docs about Kafka Transport Binding: <a href="https://github.com/cloudevent

Kafka transport about sdk-java HOT 4 CLOSED

matzew commented on August 14, 2024

Kafka transport

from sdk-java.

Comments (4)

matzew commented on August 14, 2024

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);

from sdk-java.

fabiojose commented on August 14, 2024

Done the PR #49

Let's close this?

from sdk-java.

matzew commented on August 14, 2024

/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

from sdk-java.

fabiojose commented on August 14, 2024

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

from sdk-java.

Recommend Projects