Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Fixed Kafka integration #150

Merged
merged 3 commits into from
May 17, 2022
Merged

Fixed Kafka integration #150

merged 3 commits into from
May 17, 2022

Commits on May 17, 2022

  1. Fixed Kafka integration: 

    - added the initializer to docker compose to set the Kafka topics upfront.
- fixed EventEnvelope creation to use generic one. Changed the non-generic from record to interface to make sure that it won't be used.
- made sure that EventBus takes only EventEnvelope.
- created EventEnvelope in the external publishing.
- used handler in KafkaConsumer to deserialise contracts with private constructors,
- changed KafkaConsumer setting to manually commit offset.
    @oskardudycz
    oskardudycz committed May 17, 2022
    Configuration menu
    Copy the full SHA
    6485ea9 View commit details
    Browse the repository at this point in the history

  2. Enforced EventEnvelope as a parameter of EventBus.Publish method

    @oskardudycz
    oskardudycz committed May 17, 2022
    Configuration menu
    Copy the full SHA
    e5be4e2 View commit details
    Browse the repository at this point in the history

  3. Added EventEnvelopeExtensions for Kafka message deserialisation and a… 

    …ligned with EventStoreDB subscription to all to ignore messages that's not able to deserialise
    @oskardudycz
    oskardudycz committed May 17, 2022
    Configuration menu
    Copy the full SHA
    f26c430 View commit details
    Browse the repository at this point in the history