All notable changes to this project will be documented in this file. This change log follows the conventions of keepachangelog.com.
A major release of the StreamsAgent with some breaking changes.
- Add new KeyStrategy interface: specifies how metrics data should be keyed when writing to Kpow's internal snapshots topic.
- Add two concrete implementations of
KeyStrategy
: ClientIdKeyStrategy and ClusterIdKeyStrategy. - Add new MetricFilters class: allows developers to define which metrics should be included or excluded when reporting to Kpow's internal Kafka topic. Filters can be customized to suit the needs of specific deployments or use cases.
- Removed
io.operatr
namespace - Moved deployment to io.factorhouse/kpow-streams-agent on Maven
register
method of the StreamsRegistry class has an additional argument:keyStrategy
.
- Move to
io.factorhouse
domain fromio.operatr
- Keep old
io.operatr.kpow.StreamsRegistry
entry point for backwards compatibility - Bump Kafka Streams to 3.6.1 (same as Kpow)
- Default producer
enable.idempotence
to false (avoid ACL issues with Kafka 3.2.0+) - Bump other dependencies to latest
- Update readme and images
- Bump dependencies, fix CVE-2024-22871
- Add
compression.type
to allowed Producer properties - Default Producer
compression.type
togzip
- Bump dependencies
- Additional connection fields allowed for Producer properties
- Fix
unregister
method ofio.operatr.kpow.StreamsRegistry
- Bump dependencies
- Consistent
:captured
value in snapshots sent - Improve snapshot logging+debugging
- Bump dependencies
cheshire
moved to dev dependencies
Properties
passed intoStreamsRegistry
constructor filtered to only relevant Kafka connection details. Eg, to reuse streams properties.
- Fixed project details in
pom.xml
- Explicitly set
-target
and-source
javac options to1.7
.
- Updated
project.clj
to meet requirements of deploying to Maven central.
- Underlying
StreamsRegistry
thread pool constructed with a thread factory. Improves thread names and logging.
- Fixed formatting of logging statement
io.operatr.kpow.StreamsRegistry
(initial release)