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.

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

Use last header value for JetStream messages #1239

Merged
merged 1 commit into from
Apr 9, 2024
Merged

Conversation

Jarema
Copy link
Member

@Jarema Jarema commented Apr 2, 2024

As republish will append new headers, using first value could lead to misleading data when a message is republish from one stream to another.

This commit fixes it by always picking the last header value.

reference ADR issue: nats-io/nats-architecture-and-design#250

Signed-off-by: Tomasz Pietrek <tomasz@nats.io

@Jarema Jarema requested a review from piotrpio April 9, 2024 11:46
As republish will append new headers, using first value could lead to
misleading data when a message is republish from one stream to another.

This commit fixes it by always picking the last header value.

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Copy link
Member

@neilalexander neilalexander left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@Jarema Jarema merged commit f6a8fdd into main Apr 9, 2024
11 checks passed
@Jarema Jarema deleted the use-last-header-value branch April 9, 2024 12:59
Jarema added a commit that referenced this pull request May 6, 2024
# 0.35.0

## Overview

This release makes tls setup more flexible, leveraging rusls v0.23 and allowing to pick crypto backend:
* ring
* aws-lc-rs
* fips

Some other highlights:
* force reconnect via `force_reconnect` method
* explicit create/update consumer API

Thank you for all your contributions!

## Added
* Add `ToServerAddrs` impl for array/vector of strings by @mmalek in #1231
* Add public constructor for Acker by @AbstractiveNord in #1232
* Add force reconnect by @Jarema in #1240
* Add features check by @Jarema in #1247
* Add stream placement by @Jarema in #1250
* Add consumer action by @Jarema in #1254
* Add support for aws-lc-rs (rustls v0.23.0) by @paolobarbolini in #1222

## Fixed
* Use last header value for JetStream messages by @Jarema in #1239

## Changed
* Wrap inbox prefix in an `Arc` by @thomastaylor312 in #1236
* Document feature flags by @Jarema in #1246
* Don't force flush if write buffer isn't empty by @paolobarbolini in #1241

## New Contributors
* @mmalek made their first contribution in #1231

**Full Changelog**: async-nats/v0.34.0...async-nats/v0.35.0



Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
Co-authored-by: Piotr Piotrowski <piotr@synadia.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants