V0.17.0

This release adds support for HStreamDB v0.17

New Features

• Add a method to provide gRPC metadata in the ClientBuilder
• Add an experimental StreamKeyReader

Bug fixes

• Fix the state of StreamShardReader to be terminated on termination or error
• Fix spotless format

v0.16.0

This release adds support for HStreamDB v0.16.

New Features

• Add a BatchReceiver API in Consumer
• Add a BatchReceiver API in StreamShardReader
• Add a getTailRecordId API in HStreamClient
• Add maxReadBatches, until options in StreamShardReaderBuilder

Breaking Changes

• Change shardOffset to from in StreamShardReaderBuilder

Bug Fixes

• Add lookup for Query and View APIs

v0.15.0

This release adds support for HStreamDB v0.15

Note: Reader and Queryer are deprecated now, and will be removed in the next release.

New Features

• Add a new StreamShardReader
• Add support for reading a shard from a timestamp
• Add new APIs for Query, View, Connector
• Add timestamp to ReceivedRecord

Enhancements

• Consumer notifyFailed when lookup error
• Upgrade versions of deps

Bug fixes

• Fix streamingFetch timeout in Consumer
• Fix getSubscription does not do lookup
• Fix the unit of timeout in getCoroutineStubWithTimeout

v0.13.0

This release adds support for HStreamDB v0.13

New Features

• Add support for setting request timeout in Client, Producer, Reader

Enhancements

• Add check for certificate files when enabling TLS
• Disable retry of ManagedChannel
• Upgrade grpc-java to 1.50.2

Bug fixes

• Fix maxUnackedRecords is incorrect in the return value of listSubscriptions

v0.12.0

This release adds support for HStreamDB v0.12

New Features

• Add publishTime to ReceviedRecord
• Add a new listConsumers method to HStreamClient
• Add a new getSubscription method to HStreamClient

Enhancements

• Set a default timeout for gRPC request
• Improve the schema of connection URLs, including hstream:// (plaintext connections) and hstreams:// (TLS connections)

v0.11.0

This release adds support for HStreamDB v0.11

New Features

• Add creationTime in Stream and Subscription

v0.10.0

This release adds support for HStreamDB v0.10

New Features

• Add support for e2e compression: zstd, gzip
• Add StreamBuilder

Enhancements

• Use directExecutor as default executor for grpcChannel

Bug fixes

• Fix BufferedProducer memory is not released in time
• Fix missing RecordId in Reader's results
• Fix dependency conflicts when using hstreamdb-java via maven

v0.9.0

This release adds support for HStreamDB v0.9

New Features

• Add a new createStream overloaded method with an extra shardCount parameter in HStreamClient
• Add a new listShards method in HStreamClient
• Add a new Reader interface and corresponding implementions for accessing data from a stream shard directly
• Adapt Producer and BufferedProducer to the new protocol of HStreamDB v0.9

Breaking Changes

• Replace orderingKey of Record with partitionKey

v0.8.0

New Features

• Add TLS support
• Add FlowControlSetting setting for BufferedProducer
• Add maxUnackedRecords setting for subscription
• Add backlogDurantion setting for stream
• Add force delete support for subscription
• Add force delete support for stream

Enhancements

• [Breaking change] Improve RecordId as opaque String
• Improve the performance of BufferedProducer
• Improve Responder with batched acknowledges for better performance
• Improve BufferedProducerBuilder to use BatchSetting with unified recordCountLimit, bytesCountLimit, ageLimit settings
• Improve the description of API in javadoc

Bug fixes

• Fix streamingFetch is not canceled when Consumer is closed
• Fix missing handling for grpc exceptions in Consumer
• Fix the incorrect computation of accumulated record size in BufferedProducer

v0.7.0

New Features

• Add support for transparent sharding, a new feature of HStreamDB v0.7 .
• Add BufferedProducer . For the sake of clarity, we split the original Producer into two separate BufferedProducer and Producer, where BufferedProducer is mainly for high throughput scenarios and Producer is mainly for low latency scenarios, considering that users have different requirements for write latency and throughput in different scenarios.
• Add two new flush modes for BufferedProducer. The original Producer only supports flush by the number of records in batch mode, but now BufferedProducer adds two new flush modes, size-triggered and time-triggered, and these three trigger conditions can work at the same time to meet the user's needs more flexibly.

Breaking Changes

• remove SubscriptionOffset
• remove enableBatch of Producer

Others

• upgrade log4j2 to 2.17.1 for security