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