What's Changed

• Bump OpenTelemetry and OpenTelemetry.Exporter.OpenTelemetryProtocol by @dependabot[bot] in #465
• Issue/468 - Fix infinite RESTORING when changelog buffer has past-end records by @stanb-semperis in #469
• Issue/470 - Stop leaking RocksDB iterators in RocksDbEnumerator.Dispose by @stanb-semperis in #471
• Issue/472 - Normalize retry produce timestamps to CreateTime by @stanb-semperis in #473
• Disable librdkafka statistics on clients that have no handler by @stanb-semperis in #475
• Update open telemetry dependencies by @LGouellec in #476

New Contributors

• @stanb-semperis made their first contribution in #469

Full Changelog: v1.8.1...v1.8.2

What's Changed

• Fix HasRestoredToEnd() stuck when beginOffset == endOffset (#463) by @pdouelle in #464

New Contributors

• @pdouelle made their first contribution in #464

Full Changelog: v1.8.0...v1.8.1

What's Changed

• [397] Updated MockSchemaRegistryClient with new members from Confluent.Kafka 270+ by @alex-zyl in #398
• use pattern matching for safe casts by @alex-zyl in #402
• #406 - Fix, single instance of consumer repartition forwarder by @LGouellec in #407
• #405 - Fix issue by @LGouellec in #408
• #400 - add new config property by @LGouellec in #409
• Add new periodic compaction parameter by @LGouellec in #410
• Expose message headers through ProcessorContext by @alex-zyl in #428
• Bugfix/391 exception that internally created topic exist by @wserr in #431
• Allow configuration of timeout of watermark offsets request by @AlexPorebski in #436
• Upgrade Confluent Kafka 2.12.0 by @LGouellec in #438
• Example Transformer modify Kafka Headers by @LGouellec in #442
• Issue/417 - Fix typo CreateOuputTopic instead of CreateOutputTopic by @LGouellec in #441
• Log Processing Summary for External Stream Thread configurable by @LGouellec in #440
• Make ProcessorContext#Register() public + Bytes#Wrap() public by @LGouellec in #439
• Issue/411 - Add State Store Restore Events (Start, End, Batch) by @LGouellec in #443
• Issue/415 - TopologyTestDriver is now ThreadSafe by @LGouellec in #444
• Issue/401 - Add Global Store Manually by @LGouellec in #447
• #446 - Remove deprecated API by @LGouellec in #448
• #413 - Add JsonSchemaGeneratorSettings in the constructor of the SchemaJsonS… by @LGouellec in #449
• Impl issue/434 - Change default partitioner logic and make it configurable by @LGouellec in #450
• Upgrade rocksdb to 10.4.2.63147 by @LGouellec in #452
• Issue/437 - Fix ToDictionary with duplicate keys processor for checkpoint offsets by @LGouellec in #451
• Fix typo resuffle -> reshuffle by @LGouellec in #455
• Add a programatic way to enable cache for each state store by @LGouellec in #454
• Issue/456 - Concurrency and locks exceptions by @LGouellec in #458
• Issue/457 - PROCESSING_TIME punctuations fire at 2x the scheduled interval by @LGouellec in #459
• Add AdvanceWallClockTime support for testing PROCESSING_TIME punctuations by @chrismasters in #460

New Contributors

• @alex-zyl made their first contribution in #398
• @wserr made their first contribution in #431
• @chrismasters made their first contribution in #460

Full Changelog: v1.7.0...v1.8.0

What's Changed

• [397] Updated MockSchemaRegistryClient with new members from Confluent.Kafka 270+ by @alex-zyl in #398
• use pattern matching for safe casts by @alex-zyl in #402
• #406 - Fix, single instance of consumer repartition forwarder by @LGouellec in #407
• #405 - Fix issue by @LGouellec in #408
• #400 - add new config property by @LGouellec in #409
• Add new periodic compaction parameter by @LGouellec in #410
• Expose message headers through ProcessorContext by @alex-zyl in #428
• Bugfix/391 exception that internally created topic exist by @wserr in #431
• Allow configuration of timeout of watermark offsets request by @AlexPorebski in #436
• Upgrade Confluent Kafka 2.12.0 by @LGouellec in #438
• Example Transformer modify Kafka Headers by @LGouellec in #442
• Issue/417 - Fix typo CreateOuputTopic instead of CreateOutputTopic by @LGouellec in #441
• Log Processing Summary for External Stream Thread configurable by @LGouellec in #440
• Make ProcessorContext#Register() public + Bytes#Wrap() public by @LGouellec in #439
• Issue/411 - Add State Store Restore Events (Start, End, Batch) by @LGouellec in #443
• Issue/415 - TopologyTestDriver is now ThreadSafe by @LGouellec in #444
• Issue/401 - Add Global Store Manually by @LGouellec in #447
• #446 - Remove deprecated API by @LGouellec in #448
• #413 - Add JsonSchemaGeneratorSettings in the constructor of the SchemaJsonS… by @LGouellec in #449
• Impl issue/434 - Change default partitioner logic and make it configurable by @LGouellec in #450
• Upgrade rocksdb to 10.4.2.63147 by @LGouellec in #452
• Issue/437 - Fix ToDictionary with duplicate keys processor for checkpoint offsets by @LGouellec in #451
• Fix typo resuffle -> reshuffle by @LGouellec in #455
• Add a programatic way to enable cache for each state store by @LGouellec in #454
• Issue/456 - Concurrency and locks exceptions by @LGouellec in #458
• Issue/457 - PROCESSING_TIME punctuations fire at 2x the scheduled interval by @LGouellec in #459
• Add AdvanceWallClockTime support for testing PROCESSING_TIME punctuations by @chrismasters in #460

New Contributors

• @alex-zyl made their first contribution in #398
• @wserr made their first contribution in #431
• @chrismasters made their first contribution in #460

Full Changelog: v1.7.0...v1.8.0-rc1

What's Changed

• Fix 421 - Use consumer.Position(..) in the GlobalStateManager by @LGouellec in #425
• Hotfix/421 by @LGouellec in #427

Full Changelog: v1.7.0...v1.7.1

What's Changed

• Hotfix/421 by @LGouellec in #427

Full Changelog: v1.7.1-rc1...v1.7.1-rc2

What's Changed

• Fix 421 - Use consumer.Position(..) in the GlobalStateManager by @LGouellec in #425

Full Changelog: v1.7.0...v1.7.1-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
• 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

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

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