Releases: LGouellec/streamiz
Releases · LGouellec/streamiz
V1.7.0
What's Changed
- #291 - Change Default replication factor by @LGouellec in #294
- SSL Key and Cert disclosed in logs #277 by @LGouellec in #295
- 244 configuration allow override for external consumerproducer by @LGouellec in #296
- #191 - add performance restoration test by @LGouellec in #297
- #250 add a retry behavior in the production exception handler by @LGouellec in #298
- use ConcurrentDictionary over hashmap by @tsuz in #321
- Fix ChangeLoggingTimestampedWindowBytesStore by @charleyskills in #325
- updates kafka dependency to 2.3 and fixes breaking changes by @lukasswm in #304
- 317 globalktable should provide consumer lag metrics by @LGouellec in #324
- Topic record timestamp extractor by @ppilev in #329
- Feature/197 - Caching state store by @LGouellec in #323
- 316 recordcreate factory function does not initialise headers results in null reference exception if trying to access headers by @LGouellec in #335
- Avoid full metadata call during internal topic creation process by @LGouellec in #337
- Enhancement/310 by @LGouellec in #340
- Configure independently the cache size #333 by @LGouellec in #342
- #270 - De-duplication feature by @LGouellec in #343
- Fix Issue/314 by @LGouellec in #345
- Issue/319 by @LGouellec in #351
- Fix/cache concurrent issue by @LGouellec in #348
- Add a remote storage based on the Azure Table API by @LGouellec in #339
- Issue/338 by @LGouellec in #350
- Fix issue 328 by @LGouellec in #352
- Add context in all stateless processors by @LGouellec in #357
- Topology test driver ctor publicly with kafka supplier by @LGouellec in #354
- Integration Test - Kafka native docker image by @LGouellec in #358
- Remove current record from queue when ignoring it based on negative timestamp by @AlexPorebski in #363
- Provide a Bounded Memory RocksRb config handler by @LGouellec in #371
- Exactly Once Semantics V2 by @LGouellec in #366
- KIP-607 Support by @LGouellec in #369
- KIP-328 : Feature/suppress by @LGouellec in #377
- Fix and Change the default value for "PartitionAssignmentStrategy" by @LGouellec in #378
- dispose of AdminClient when closing KafkaStream by @AlexPorebski in #379
- Sequentially close the external stream thread by @LGouellec in #380
- #382 - Fix InMemoryWindowStore concurrent issue by @LGouellec in #384
- #385 - Fix EOS duplicate handle - Client is fenced by @LGouellec in #388
- No checkpoint when the partition is empty by @LGouellec in #389
- Open telemetry reporter - Use an AddOtlpExporter by @LGouellec in #393
- Support Confluent Cloud CSFLE by @LGouellec in #394
- Public API - Connect state store and processor by @LGouellec in #395
- Dangling tasks fix 2 by @maciejniepokoj in #396
- Dangling tasks fix 2 by @AlexPorebski in #386
New Contributors
- @tsuz made their first contribution in #321
- @charleyskills made their first contribution in #325
- @lukasswm made their first contribution in #304
- @AlexPorebski made their first contribution in #363
- @maciejniepokoj made their first contribution in #396
Full Changelog: v1.5.1...v1.7.0
Contributors
LGouellec, tsuz, and 5 other contributors
Assets 2
V1.7.0-RC2
What's Changed
- Dangling tasks fix 2 by @maciejniepokoj in #396
- Dangling tasks fix 2 by @AlexPorebski in #386
New Contributors
- @maciejniepokoj made their first contribution in #396
Full Changelog: v1.7.0-rc1...v1.7.0-rc2
Contributors
AlexPorebski and maciejniepokoj
Assets 2
V1.7.0-RC1
What's Changed
- Topic record timestamp extractor by @ppilev in #329
- Feature/197 - Caching state store by @LGouellec in #323
- 316 recordcreate factory function does not initialise headers results in null reference exception if trying to access headers by @LGouellec in #335
- Avoid full metadata call during internal topic creation process by @LGouellec in #337
- Enhancement/310 by @LGouellec in #340
- Configure independently the cache size #333 by @LGouellec in #342
- #270 - De-duplication feature by @LGouellec in #343
- Fix Issue/314 by @LGouellec in #345
- Issue/319 by @LGouellec in #351
- Fix/cache concurrent issue by @LGouellec in #348
- Add a remote storage based on the Azure Table API by @LGouellec in #339
- Issue/338 by @LGouellec in #350
- Fix issue 328 by @LGouellec in #352
- Add context in all stateless processors by @LGouellec in #357
- Topology test driver ctor publicly with kafka supplier by @LGouellec in #354
- Integration Test - Kafka native docker image by @LGouellec in #358
- Remove current record from queue when ignoring it based on negative timestamp by @AlexPorebski in #363
- Provide a Bounded Memory RocksRb config handler by @LGouellec in #371
- Exactly Once Semantics V2 by @LGouellec in #366
- KIP-607 Support by @LGouellec in #369
- KIP-328 : Feature/suppress by @LGouellec in #377
- Fix and Change the default value for "PartitionAssignmentStrategy" by @LGouellec in #378
- dispose of AdminClient when closing KafkaStream by @AlexPorebski in #379
- Sequentially close the external stream thread by @LGouellec in #380
- #382 - Fix InMemoryWindowStore concurrent issue by @LGouellec in #384
- #385 - Fix EOS duplicate handle - Client is fenced by @LGouellec in #388
- No checkpoint when the partition is empty by @LGouellec in #389
- Open telemetry reporter - Use an AddOtlpExporter by @LGouellec in #393
- Support Confluent Cloud CSFLE by @LGouellec in #394
- Public API - Connect state store and processor by @LGouellec in #395
New Contributors
- @AlexPorebski made their first contribution in #363
Full Changelog: v1.6.0-rc1...v1.7.0-rc1
Contributors
LGouellec, ppilev, and AlexPorebski
Assets 2
V1.6.0
What's Changed
- #291 - Change Default replication factor by @LGouellec in #294
- SSL Key and Cert disclosed in logs #277 by @LGouellec in #295
- 244 configuration allow override for external consumerproducer by @LGouellec in #296
- #191 - add performance restoration test by @LGouellec in #297
- #250 add a retry behavior in the production exception handler by @LGouellec in #298
- use ConcurrentDictionary over hashmap by @tsuz in #321
- Fix ChangeLoggingTimestampedWindowBytesStore by @charleyskills in #325
- updates kafka dependency to 2.3 and fixes breaking changes by @lukasswm in #304
- 317 globalktable should provide consumer lag metrics by @LGouellec in #324
- Topic record timestamp extractor by @ppilev in #329
- Feature/197 - Caching state store by @LGouellec in #323
New Contributors
- @tsuz made their first contribution in #321
- @charleyskills made their first contribution in #325
- @lukasswm made their first contribution in #304
Full Changelog: v1.5.1...v1.6.0
Contributors
LGouellec, tsuz, and 3 other contributors
Assets 2
V1.6.0-RC2
What's Changed
- Topic record timestamp extractor by @ppilev in #329
- Feature/197 - Caching state store by @LGouellec in #323
Full Changelog: v1.6.0-rc1...v1.6.0-rc2
Contributors
LGouellec and ppilev
Assets 2
V1.6.0-RC1
What's Changed
- #291 - Change Default replication factor by @LGouellec in #294
- SSL Key and Cert disclosed in logs #277 by @LGouellec in #295
- 244 configuration allow override for external consumerproducer by @LGouellec in #296
- #191 - add performance restoration test by @LGouellec in #297
- #250 add a retry behavior in the production exception handler by @LGouellec in #298
- use ConcurrentDictionary over hashmap by @tsuz in #321
- Fix ChangeLoggingTimestampedWindowBytesStore by @charleyskills in #325
- updates kafka dependency to 2.3 and fixes breaking changes by @lukasswm in #304
- 317 globalktable should provide consumer lag metrics by @LGouellec in #324
New Contributors
- @tsuz made their first contribution in #321
- @charleyskills made their first contribution in #325
- @lukasswm made their first contribution in #304
Full Changelog: v1.5.1...v1.6.0-rc1
Contributors
LGouellec, tsuz, and 2 other contributors
Assets 2
V1.5.1
What's Changed
- Offer manual control over Grace MS settings by @yasinparsi in #282
- Can't instantiate a new instance of StreamTableJoinProps<> by @LGouellec in #289
- Issue/275 by @LGouellec in #290
- Add state stores through StreamBuilder by @ppilev in #284
New Contributors
- @yasinparsi made their first contribution in #282
Full Changelog: v1.5.0...v1.5.1
Contributors
LGouellec, ppilev, and yasinparsi
Assets 2
V1.5.0
What's Changed
- fix: ordering of error log parameters by @masteryee in #224
- change default partitioner + change visibility to PartitionAssignment… by @LGouellec in #219
- 144 refactor internal streamiz configuration by @LGouellec in #231
- 201 add support for processorcontextforward by @LGouellec in #230
- Add Logging processing summary by @LGouellec in #233
- 221 possibility to explicitly configure keyvalue serdes for kstreamktable join is missing by @LGouellec in #240
- Cloudevents support by @LGouellec in #241
- feat(Record): add Record.WithHeaders by @attributeerror in #239
- 218 prometheux exporter cant expose state store metrics if the topology contains rocksdb and in memory store by @LGouellec in #242
- 199 add support for punctuators scheduled tasks by @LGouellec in #246
- 248 upgrade confluentkafka to 210 by @LGouellec in #257
- add support for stream record timestamp extractor by @ppilev in #255
- flip beforeMs and afterMs values for right KStreamKStreamJoin by @ppilev in #249
- 190 support duplicates window store by @LGouellec in #258
- StreamConfig initialization with options pattern by @ppilev in #265
- 223 application crashes while rebalancing by @LGouellec in #259
- 271 Fix Window InMemoryStore restoration
- Upgrade Confluent.Kafka to 2.2.0
New Contributors
- @masteryee made their first contribution in #224
- @attributeerror made their first contribution in #239
- @ppilev made their first contribution in #255
Full Changelog: v1.4.2...v1.5.0
V1.5.0-RC2
Full Changelog: v1.5.0-rc1...v1.5.0-rc2
V1.5.0-RC1
What's Changed
- fix: ordering of error log parameters by @masteryee in #224
- change default partitioner + change visibility to PartitionAssignment… by @LGouellec in #219
- 144 refactor internal streamiz configuration by @LGouellec in #231
- 201 add support for processorcontextforward by @LGouellec in #230
- Add Logging processing summary by @LGouellec in #233
- 221 possibility to explicitly configure keyvalue serdes for kstreamktable join is missing by @LGouellec in #240
- Cloudevents support by @LGouellec in #241
- feat(Record): add Record.WithHeaders by @attributeerror in #239
- 218 prometheux exporter cant expose state store metrics if the topology contains rocksdb and in memory store by @LGouellec in #242
- 199 add support for punctuators scheduled tasks by @LGouellec in #246
- 248 upgrade confluentkafka to 210 by @LGouellec in #257
- add support for stream record timestamp extractor by @ppilev in #255
- flip beforeMs and afterMs values for right KStreamKStreamJoin by @ppilev in #249
- 190 support duplicates window store by @LGouellec in #258
- StreamConfig initialization with options pattern by @ppilev in #265
- 223 application crashes while rebalancing by @LGouellec in #259
New Contributors
- @masteryee made their first contribution in #224
- @attributeerror made their first contribution in #239
- @ppilev made their first contribution in #255
Full Changelog: v1.4.2...v1.5.0-rc1
Contributors
LGouellec, masteryee, and 2 other contributors