Skip to content

Fluxzero 1.190.0

Choose a tag to compare

View all tags
@github-actions github-actions released this 02 Jun 16:50
1.190.0
c5cc41b

1.190.0 (2026-06-02)

Features

  • feat(tracking): limit read batches by payload bytes (77fa846)

    Add maxFetchBytes/maxBytes to tracking read configuration and wire protocol so clients can request batches bounded by serialized payload bytes as well as message count.

    Apply the limit in common tracking, local/cache/direct read paths, and the test server while preserving progress for a first oversized message and backward-compatible decoding when maxBytes is absent.

    Tests:\n./mvnw -pl common,sdk,test-server -am -Dtest=DefaultTrackingStrategyTest,WebSocketTransportCodecsTest,InMemoryMessageStoreTest,TestServerReadLimitsTest -Dsurefire.failIfNoSpecifiedTests=false test\ngit diff --check

Bug Fixes

  • fix(common): cap backlog batch allocation (c5cc41b)
  • fix(websocket): reuse JDK client in connector (be3e5d0)

    Derive one internal HttpClient per JdkWebsocketConnector instead of creating one for every websocket connection. Keep successful handshake header capture via a shared CookieHandler wrapper and per-handshake Sec-WebSocket-Accept mapping so runtime session metadata remains isolated per connection.

    Tests run:

    - ./mvnw -pl sdk -Dtest=JdkWebsocketConnectorTest test

    - ./mvnw -pl sdk -am test

    - ./mvnw -pl proxy -am test

    - ./mvnw clean install

  • fix(tracking): scan reads with byte-aware filters (96ae2c8)

    Push tracking read filtering into MessageStore scans so maxBytes can be applied while scanning accepted messages instead of after materializing an unfiltered batch.

    Return scan metadata with accepted messages so DefaultTrackingStrategy can keep unfiltered source progress while avoiding cursor skips when a byte limit stops before the next matching message.

    Tests:\n./mvnw -pl common,sdk,test-server -am -Dtest=DefaultTrackingStrategyTest,WebSocketTransportCodecsTest,InMemoryMessageStoreTest,TestServerReadLimitsTest -Dsurefire.failIfNoSpecifiedTests=false test\n./mvnw -pl sdk,test-server -am -Dtest=LocalTrackingClientTest,TestServerScheduleStoreTest -Dsurefire.failIfNoSpecifiedTests=false test\ngit diff --check

Assets 4
Loading