Skip to content

feat: add attributes support to ConsumedRecord and related matchers - #56

Merged
nil-malh merged 3 commits into
mainfrom
feat/55
Aug 9, 2026
Merged

feat: add attributes support to ConsumedRecord and related matchers#56
nil-malh merged 3 commits into
mainfrom
feat/55

Conversation

@nil-malh

@nil-malh nil-malh commented Aug 7, 2026

Copy link
Copy Markdown
Contributor

📝 Description

Resolves #55

🔄 Type of Change

  • New feature — non-breaking change that adds functionality

✅ Pre-Merge Checklist

Code Quality

  • My code follows the Palantir Java Format style (passes mvn spotless:check)
  • I have added or updated Javadoc on public types and methods

Tests

  • I have added unit tests that cover the new / changed behaviour
  • All existing and new tests pass locally (mvn verify)
  • JaCoCo line coverage ≥ 70 % is maintained
  • Tests using Testcontainers are isolated and do not leave containers running

Licensing

  • Apache 2.0 license header has been added to every new source file (using spotless)

@github-actions

github-actions Bot commented Aug 7, 2026

Copy link
Copy Markdown
Contributor

📋 Unreleased Changelog Preview

This is what the next release notes will look like based on commits in this PR.

Changelog

All notable changes to this project will be documented in this file.

[Unreleased]

✨ Features

  • Add attributes support to ConsumedRecord and related matchers

  • Reorganize imports for consistency and clarity across multiple files


Generated by git-cliff


🔄 Run #140 · Fri, 07 Aug 2026 12:37:11 GMT

/**
* Full constructor including transport {@link #attributes}.
*
* @param source the source topic / queue / channel name
* Full constructor including transport {@link #attributes}.
*
* @param source the source topic / queue / channel name
* @param partition the partition index, {@code 0} for non-partitioned sources
*
* @param source the source topic / queue / channel name
* @param partition the partition index, {@code 0} for non-partitioned sources
* @param offset the offset within the partition, {@code -1} when the source has no offset concept
* @param source the source topic / queue / channel name
* @param partition the partition index, {@code 0} for non-partitioned sources
* @param offset the offset within the partition, {@code -1} when the source has no offset concept
* @param key the record key, may be {@code null}
* @param partition the partition index, {@code 0} for non-partitioned sources
* @param offset the offset within the partition, {@code -1} when the source has no offset concept
* @param key the record key, may be {@code null}
* @param value the deserialized record value
* @param offset the offset within the partition, {@code -1} when the source has no offset concept
* @param key the record key, may be {@code null}
* @param value the deserialized record value
* @param timestamp the timestamp at which the record was written to the source
* @param key the record key, may be {@code null}
* @param value the deserialized record value
* @param timestamp the timestamp at which the record was written to the source
* @param headers the transport-level headers, may be {@code null} (treated as empty)
* @param value the deserialized record value
* @param timestamp the timestamp at which the record was written to the source
* @param headers the transport-level headers, may be {@code null} (treated as empty)
* @param attributes the transport-specific metadata, may be {@code null} (treated as empty)
@github-actions

github-actions Bot commented Aug 7, 2026

Copy link
Copy Markdown
Contributor

✅ Test Results

Metric Count
Passed 716
Failed 0
⏭️ Skipped 0
📊 Total 716

✅ Coverage

Type Coverage Covered / Total
📏 Lines 84.2% 1871 / 2222
🌿 Branches 73.7% 581 / 788
🔧 Methods 84.6% 385 / 455

🔄 CI run #159 · Fri, 07 Aug 2026 12:40:35 GMT

@nil-malh
nil-malh merged commit b63325f into main Aug 9, 2026
10 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Feature]: Add a synchronous request/response transport contract

1 participant