Versions Compared

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 static