Skip to content

v3.6.0
Compare
Choose a tag to compare
@BEagle1984 BEagle1984 released this 04 Mar 17:05
· 92 commits to master since this release
v3.6.0
b6894f6
  • Handle IAsyncEnumerable<T> returned by the subscriber and republished the contained messages
  • Enrich Kafka messages moved by the MoveMessageErrorPolicy adding some extra headers containing some information about the source topic, partition, offset, etc.
  • Allow filters such as the KafkaGroupIdFilterAttribute or MqttClientIdFilterAttribute to be added to the subscribers at runtime via the configuration API
  • Add overload for Publish method in the error policies that forwards the exception as well as the envelope
  • Throw TimeoutException from KafkaTestingHelper and MqttTestingHelper
  • Improve MQTT connection related logs (info for successful reconnect and add broker name to log messages)
  • Support shared sessions in mocked MQTT broker
  • Ensure each consumed message gets a unique traceId (when the traceparent header is not present)
  • Fix memory leak in consumer
  • Fully validate messages, including nested objects

See docs for details.

Assets 2
Loading