Versions Compared

Old Version 37

changes.mady.by.user Sébastien Viale

Saved on

compared with

New Version 38

changes.mady.by.user Sébastien Viale

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Managing DeadLetterQueue directly in the DSL by extending the KStreams interface.
  • Providing no default implementation to build the Dead letter queue record and delegating this task to the user.
  • Only providing exception and metadata information in the default DLQ implementation.
  • Adding a new interface, that could be overloaded by the user, to build the DLQ records.
  • Adding dead letter queue records to the enum: a shared collection cannot be used across all stream threads within an enum because it would be staticproblematic because the collection would be shared by all stream threads, leading to unnecessary concurrency and potential transaction issues.