Releases: eschizoid/kpipe
Releases · eschizoid/kpipe
Release list
Release v1.16.3
Changelog
🐛 Fixes
- 3fd79fe logging: dedup unrouted-key WARN, drop per-record INFO spam, attach throwables (#210), closes #210
- 7a82762 consumer: close resources on constructor-failure paths (#209), closes #209
- 04e67be include offending value + remediation in validation error messages (#208), closes #208
- f7dd94e format: enrich SerDe error messages with format name + byte context (#207), closes #207
- be1b873 api: MultiBuilder rejects silently-dropped per-route consumer-wide settings (#199), closes #199
🔄️ Changes
- 36ba4e1 consumer: cache TopicPartition per partition in KafkaOffsetManager + add JMH benchmark (#205), closes #205
- 79d9b13 hot-path quick wins — hoist getSimpleName, batch scratch buffer + BitSet, drop KeyOrdered wrapper (#203), closes #203
- cade7d6 api: normalize KPipe.avro/protobuf arg order to (topic, props, format) (#201), closes #201
🧪 Tests
🧰 Tasks
- 554c54b jpms: remove unused requires, promote API-exposed deps to transitive (#206), closes #206
- 01417c0 tighten Builder null-validation + dlqTopic blank-check + reference Backpressure constants (#202), closes #202
📝 Documentation
- bbdb36e harden audit-review comments on non-obvious correctness (#211), closes #205 #207 #209 #210 #211
- 3610f5d fix package-info example, drop stale processToSink refs (#200), closes #200
Contributors
We'd like to thank the following people for their contributions:
GitHub, Mariano Gonzalez
Release v1.16.2
Changelog
🧪 Tests
- 4ccac98 producer: pin KafkaMessageSink error paths (#192), closes #192
- 816123d schema-registry: pin CachedSchemaResolver failure-caching contract (§19) (#193), closes #193
- b5943b1 producer: pin Tracer header injection through DLQ (#191), closes #191
- ce49886 consumer: pin BatchPipelineWrapper coverage-contract paths (#188), closes #188
- 165b5dc consumer: pin ParallelDispatcher pendingCount + onComplete race paths (#186), closes #186
- 6bf214c pin three coverage follow-ups from recent reviews (#185), closes #167 #168 #170 #185
🧰 Tasks
- 8127074 tracing-otel: inline HeadersTextMap{Getter,Setter} into OtelTracer (#198), closes #198
- c10b8a1 test-fixtures: inline triplicated CapturingHandler into per-module *ConsoleSinkTest (#197), closes #197
- 5573fb8 schema-registry: delete unused CachedSchemaResolver.invalidateAll() (#196), closes #196
- c43852a format-avro: delete dead AvroFormat.isRegistryBacked() (#195), closes #195
- a15b2c2 format-json: tighten JsonFormat no-arg ctor to private (#194), closes #194
- df9c1d8 roundup of worth-considering nits from review fleet (#190), closes #190
- eb21492 delete dead Catalog classes + test-only withers (post-audit cleanup) (#187), closes #187
- 5fad212 consumer: drop CircuitBreakerController.shouldProbe + fix docs (#189), closes #170 #189
📝 Documentation
- 0e86d8d examples: add KPipe.custom-format example (refs #166) (#184), closes #166 #184
- 491a9a8 examples: add KPipe.bytes example (refs #166) (#183), closes #166 #183
Contributors
We'd like to thank the following people for their contributions:
GitHub, Mariano Gonzalez
Release v1.16.1
Changelog
🐛 Fixes
- 6ea43a0 ci: restore jgit auth in release workflow after actions/checkout v7 (#182), closes #182
- eb919ba consumer: document and assert single-writer invariant for commandQueue drain (closes #163) (#168), closes #163 #168
- d7e4289 release: publish every :lib module, not just the hand-listed ten (#157), closes #157
🔄️ Changes
- d3a5132 consumer: inline RebalanceListener as anon class in KafkaOffsetManager (closes #55) (#162), closes #55 #162
🧪 Tests
- 07f02dd consumer: pin remaining §20 dispatcher invariants (closes #164) (#167), closes #164 #167
- 9d1bad7 assert OTel metrics emission against a real SDK + tighten OtelSpanScope (#160), closes #160
🧰 Tasks
- 2103da0 inline Noop tracer/span singletons + delete dead RegistryFunctions methods (#170), closes #165 #170
- 2afd23a address IntelliJ inspection warnings repo-wide (comprehensive sweep) (#161), closes #161
🛠 Build
- 50d524e ignore release toolchain (jgit + axion + jreleaser) in Dependabot (#181), closes #181
- 95a026c deps: bump actions/checkout from 4 to 7 (#172), closes #172
- 953dfd8 deps: bump codecov/codecov-action from 5 to 7 (#173), closes #173
- 6804f42 deps: bump gradle/actions from 3 to 6 (#176), closes #176
- 7f2f108 deps: bump actions/setup-java from 4 to 5 (#175), closes #175
- 197ee30 deps: bump crazy-max/ghaction-import-gpg from 6 to 7 (#174), closes #174
- 830b750 add Dependabot config for Gradle and GitHub Actions (#171), closes #171
📝 Documentation
- bba3e6e rewrite README full-application sketch using fluent facade (refs #166) (#169), closes #166 #169
- 6d6a853 deps: bump the gradle-minor-patch group with 23 updates (#177), closes #177
- d0997c8 deps: bump io.confluent.parallelconsumer:parallel-consumer-core (#180), closes #180
- d417fed deps: bump com.gradleup.shadow from 8.3.5 to 9.4.2 (#178), closes #178
- ce0fde5 bump kafka-clients + Testcontainers Kafka image to 4.3.0 (#159), closes #159
- 64f26ec Fix/jreleaser publish all lib modules (#158), closes #158
Contributors
We'd like to thank the following people for their contributions:
GitHub, Mariano Gonzalez, dependabot[bot], mariano
Release v1.16.0
Changelog
🔄️ Changes
🧪 Tests
🧰 Tasks
📝 Documentation
- 802197d drop internal CLAUDE.md §N references — state the rule directly (#152), closes #152
- 35d05a2 readme: clarify client-side parallelism and scaling by consumer count
- 510fbb0 extend workMicros sweep to 10/35/50/100ms (refs #148) (#153), closes #148 #151 #153 #420
- c221b4f restore JsonPipelineBenchmark + AvroPipelineBenchmark (closes #151) (#154), closes #151 #154
Contributors
We'd like to thank the following people for their contributions:
GitHub, Mariano Gonzalez, mariano
Release v1.15.1
Changelog
🔄️ Changes
🧰 Tasks
📝 Documentation
- 274591c address #136 review (single-thread, CPC KEY+PARTITION, ordering-tax view) (#140), closes #136 #140
- 1c564cb add Share Consumer (KIP-932) + KPipe KEY_ORDERED arms (#138), closes #138
Contributors
We'd like to thank the following people for their contributions:
GitHub, Mariano Gonzalez
Release v1.15.0
Release v1.14.1
Release v1.14.0
Changelog
📝 Documentation
- d95fded correct three README claims about ScopedValue (not actually used) (#121), closes #121
- cfe1889 refresh PLAN.md for 1.13.0 + add
just releasetask (#120), closes #115 #117 #120
- 149df56 1.14 bundle — registry rename, deser hints, Stream observers, SR auto-lookup, observability, escape-hatches doc (#134), closes #134
- bd45016 first 4-runtime results + disable Reactor row (upstream kafka-clients 4.x incompat) (#133), closes #133 #420
- 38d1671 re-architect on Testcontainers Kafka so the broker stops being the bottleneck (#132), closes #132
- daa357a disable idempotence on the seed producer to silence test-kit OOO errors (#131), closes #131
- d9ef4d6 recover METHODOLOGY.md, results/TEMPLATE.md, ParallelProcessingLatencyBenchmark (#129), closes #123 #124 #129
- 18b71bd add
just benchtarget wrapping the parallel-consumer benchmark (#130), closes #129 #130 - fed2c16 tune defaults for in-process broker after smoke-test findings (#128), closes #122 #128
- 56ee4ee expand parallel suite to KPipe vs Confluent PC vs Reactor Kafka vs raw KafkaConsumer (#122), closes #122
Contributors
We'd like to thank the following people for their contributions:
GitHub, Mariano Gonzalez
Release v1.13.0
Changelog
🚀 Features
🔄️ Changes
- 71f99f3 consumer: collapse pause/backpressure/CB into ConsumerHealthController (1.13.0) (#118), closes #118
- 4663f03 format: split Avro/Protobuf codec from schema catalog (1.13.0) (#117), closes #117
- 9eb86b4 core: collapse MessageSinkRegistry into MessageProcessorRegistry (#105), closes #3 #105
🛠 Build
- c666166 include kpipe-schema-registry-confluent + kpipe-tracing-otel in coverage and release (#119), closes #119
- d6b158a upload JUnit test results to Codecov Test Analytics (#116), closes #116
📝 Documentation
- 3c7012d consumer: add javadoc @param/@return on CB + EntryMetricsReporter (#114), closes #105 #106 #114
- c4a9263 core: add javadoc @param/@return tags on MessageProcessorRegistry methods
- 20283c6 api: document the deliberate phantom T on Sink
- 52ea797 land #106 + #107 + #108 + #109 + #110 + #112 content + HIGH/MEDIUM/LOW review fixes (#113), closes #1 #2 #106 #107 #108 #109 #110 #112 #113
- ff5614c Feature/docs sweep (#104), closes #6 #7 #102 #104
- 8138465 Feature/circuit breaker (#103), closes #7 #103
Contributors
We'd like to thank the following people for their contributions:
GitHub, Mariano Gonzalez, mariano
Contributors
return