v2.1.1
- Multiple message brokers (Kafka and RabbitMQ) can be used together in the same application
- End-to-End message encryption
- Dynamic custom routing of outbound messages
- Better support for message headers
- Binary files support
- The
IIntegrationMessage
is not required to have anId
property anymore (thex-message-id
header will still be generated and if the property exists will continue to be automatically initialized) x-first-chunk-offset
header added by default- [kafka] The
KafkaStasticsEvent
JSON is now being deserialized and provided as object (in addition to the raw JSON) - [kafka] Added support for Apache Avro and schema registry
- [kafka] Upgrade to Confluent.Kafka 1.4.2
- [rabbit] Added consumer
PrefetchSize
andPrefetchCount
settings - [rabbit] Added
AcknowledgeEach
to theRabbitConsumerEndpoint
to define the number of message processed before sending the acknowledgment to the server - [rabbit] Upgrade to RabbitMQ.Client 6.0.0
- Improved message type resolution performance and reliability in
JsonMessageSerializer
LogWithLevel
method added toSkipMessageErrorPolicy
to specify the desired level for the "Message skipped" log entry (the default is now increased toError
)
See docs for details.