5.4.0
What's Changed
- BMM Restart Improvements Part 2. Followers claim their tokens after handling stop assignments by @jzakaryan in #921
- BMM Restart Improvements Part 3. Leader polls for unclaimed tokens before declaring a datastream STOPPED by @jzakaryan in #922
- BMM Restart Improvements Part 4. Edge cases, cleanup and general improvements by @jzakaryan in #924
- Moved the datastream stop check poll to a separate thread to avoid blocking the event queue by @jzakaryan in #925
- BMM Restart Improvements: Bug fixes and logging improvements by @jzakaryan in #926
- Bump Kafka version by @vmaheshw in #929
- Handling Metrics and SLA Reporting for Throughput Violating Topics via Datastream Update API Part 1 by @shrinandthakkar in #928
- Added Support and Handling For Generic Headers by @shrinandthakkar in #931
- Minor improvements w.r.t #928 & Releasing a newer version by @shrinandthakkar in #932
- Exposed the Kafka Connector's task interrupt timeout as config by @jzakaryan in #933
- Separated Metrics Handling for Throughput Violating Topics by @shrinandthakkar in #930
- Released New Version 5.3.2 by @shrinandthakkar in #935
- Increased the size of token claims thread pool by @jzakaryan in #938
- Audit START/END log events for CoordinatorEvent operations by @ehoner in #936
- Add metrics for CoordinatorEvent queue by @ehoner in #937
- Minor improvements for assignment tokens feature by @jzakaryan in #941
- Fix Metric Registration Issue for Throughput Violations Reporting by @shrinandthakkar in #942
- Fix tests and reduce the overall test execution time by @vmaheshw in #939
- Fixes for NoOpTransportProvider by @jzakaryan in #940
- Add stop method to TransportProviderAdmin by @vmaheshw in #944
- Log existing datastream for update and delete call by @vmaheshw in #948
- EventQueue metrics are not exported by @ehoner in #945
- Added log messages to debug assignPartitions by @jzakaryan in #951
- Replacing Coordinator Queue With Deque & Fixing Usage Of toMap Util by @shrinandthakkar in #950
- Fixing Flaky Test testLeaderDoAssignmentForNewlyElectedLeaderFailurePathVariation by @shrinandthakkar in #953
- Minor version release - 5.4.0 by @ehoner in #954
Full Changelog: 5.1.0...5.4.0