- Add unstable Admin Watch API for topics, partitions, and SPUs (#1136)
- Make recipes for smoke tests no longer build by default, helps caching. (#1165)
- Relax requirement of
FluvioAdmin
methods from&mut self
to&self
. (#1178)
- Don't hang when check for non exist topic. (#697)
fluvio cluster start
uses Kubernetes NodePort by default (#1083)- Use OpenSSL for Client (#1150)
- Add
--raw
flag tofluvio produce
for sending whole file input (#1149)
- Added builder for fluvio_storage::config::ConfigOption. (#1076)
- Use batch record sending in CLI producer (#915)
- Now ResponseApi and RequestApi encoder-decoders are symmetric (#1075)
FluvioCodec
encoder now supportsFluvioEncoder
types. Implementation with bytes::Bytes now is deprecated. (#1076)- Added implementations of FluvioEncoder for &T: FluvioEncoder. (#1081)
- Updated RecordAPI with RecordKey and RecordData (#1088)
- Support WASM for client (#1101)
spu_pool
to support wasm runtime. (#1106)- Remove async trait for more wasm support to client (#1108)
- Better logging for SPU health check (#1109)
- fluvio-socket build for wasm32 (#1111)
- Add Fluvio::connect_with_connector to support custom connectors. (#1120)
- Fix Replication fail over with duplication (#1052)
- Relax platform version requirement for upgrade check (#1055)
- Update logic for finding latest package release (#1061)
- Use file name for the external commands (fixes #889) (#1008)
- Fix Fluvio log directory on K8 (#1043)
- Add RecordKey API for sending records without keys (#985)
- Make Fluvio Client compatitble with WASM (#1042)
- Update Replication logic for SPU (#1011)
- Added Partitioner trait for assigning partitions based on record keys (#965)
- Deprecated the
TopicProducer::send_record
method (#965) - Decoupled Fluvio CLI from Fluvio server components (#928)
- Added batching for producing records with
send_all
API (#896). - WASM based Smart Stream Filter MVP (#901).
- Fix topic not being deleted when SPU goes offline (#914)
fluvio update
updates plugins as well as CLI (#865).- SPU controller uses SVC ingress annotation (#888).
- Client Key/Value support for producers and consumers (#828).
- CLI Key/Value interface (#830)
- CI Reliability updates (#842), (#832)
fluvio cluster upgrade
(#709)install.sh
script works withVERSION=latest
for prereleases(#812)- Fix stream fetch (#769)
- Limit for batchsize (#787)
- Protocol updates (#752)
- Socket close events propigate to client (infinyon/fluvio-socket#22)
- Fix sha256 has in
fluvio version
(#740) - Implement flush policy to flush on a delay time after writes (#694)
- Create basedir during
fluvio install
if missing (#739)
- Protocol changes to encode vector lengths in
DefaultAsyncBuffer
andRecordSets
(#752).
- Added
bytes
andbytes_ref
forRecord
and removingtry_into_bytes
(#706)
- Restore Ok (#675)
- Expose Consumer Record (#687)
- Stand alone Installer
- Support for Writing Extension
- Self Update Capability
- Profile rename
- Show Platform versions
- API Docs
- Stream based Fetch
- Cluster Installer with API and CLI support
- Support for Installing in Minikube without workaround
- Delete Topic
- Pluggable Authorization Framework with simple RBAC
- TLS endpoint for SC and SPU
- Connection multiplexing
- Support Rasberry Pi
- Use tracing instead of logger
- Github Action to test Platform
- K8: Enforce resource limit on Kubernetes
- Consolidate Custom SPU and SPU
- Better error messages
- Move TLS as global option
- Fully multi-threaded consumer and producer
- Better stability
- K8: Fix storage location