evolution-gaming / skafka / 27696343346

80%

Build Type

push

Committed by web-flow

Commit Message

Add Producer.sendOffsetsToTransaction (#575)

* Add Producer.sendOffsetsToTransaction

Expose KafkaProducer.sendOffsetsToTransaction(offsets, ConsumerGroupMetadata) on
the Producer trait and all implementations (live, empty, with-metrics, logging,
mapK). This enables KIP-447 consumer-generation fencing for transactional offset
commits - e.g. binding input-topic offset commits into a state-store transaction
so a stale consumer generation is fenced from committing.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

* Wire up metrics, mima filter and tests for sendOffsetsToTransaction

- Record metrics.sendOffsetsToTransaction in the WithMetrics wrapper,
  matching commit/abortTransaction (the metric existed but was unused)
- Add ReversedMissingMethodProblem filter for the new Producer trait
  method so versionPolicyCheck passes (per the v19.1.0 convention)
- Add ProducerSpec coverage for proxy and empty producer

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

* second pass

---------

Co-authored-by: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Coverage Stats

17 of 17 new or added lines in 1 file covered. (100.0%)

39 existing lines in 1 file now uncovered.

2322 of 2890 relevant lines covered (80.35%)

1.29 hits per line