Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 9 additions & 3 deletions sdk/messaging/azeventhubs/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,11 @@
# Release History

## 2.0.2 (2026-03-10)

### Bugs Fixed

- Added immediate retry for AMQP link detach errors, avoiding unnecessary backoff delays when errors originate from earlier detaches. (PR#25630)

## 2.0.1 (2025-10-08)

### Bugs Fixed
Expand All @@ -8,11 +14,11 @@

## 2.0.0 (2025-06-10)

First release of `github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs/v2`.
First release of `github.com/Azure/azure-sdk-for-go/sdk/messaging/azeventhubs/v2`.

### Breaking Changes

This new major release is compatible with azeventhubs v1, with one difference - Checkpoint.Offset and ReceivedEventData.Offset's type have been changed to a string (from an integer).
This new major release is compatible with azeventhubs v1, with one difference - Checkpoint.Offset and ReceivedEventData.Offset's type have been changed to a string (from an integer).
This change does NOT affect any stored checkpoints. Most customers will be unaffected by this change and can safely upgrade.

### Features Added
Expand All @@ -27,7 +33,7 @@ This change does NOT affect any stored checkpoints. Most customers will be unaff

### Breaking Changes

- This package is compatible with azeventhubs v1, with one difference - Checkpoint.Offset and ReceivedEventData.Offset's type have been changed to a string (from an integer).
- This package is compatible with azeventhubs v1, with one difference - Checkpoint.Offset and ReceivedEventData.Offset's type have been changed to a string (from an integer).
This change does NOT affect any stored checkpoints. Most customers will be unaffected by this change and can safely upgrade.

## 1.3.2 (2025-04-08)
Expand Down
2 changes: 1 addition & 1 deletion sdk/messaging/azeventhubs/internal/constants.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
package internal

// Version is the semantic version number
const Version = "v2.0.1"
const Version = "v2.0.2"

// CapabilityGeoDRReplication is passed as part of our desired capabilities when creating links.
const CapabilityGeoDRReplication = "com.microsoft:georeplication"
Original file line number Diff line number Diff line change
Expand Up @@ -327,7 +327,7 @@ func (inf *processorStressTest) report(ctx context.Context, header string, endPo

stats := strings.Builder{}

stats.WriteString(fmt.Sprintf("=== Stats (%s) ===\n", header))
fmt.Fprintf(&stats, "=== Stats (%s) ===\n", header)

done := 0

Expand Down Expand Up @@ -355,7 +355,7 @@ func (inf *processorStressTest) report(ctx context.Context, header string, endPo
done++
}

stats.WriteString(fmt.Sprintf(" [%s] o:%s (last: %s), remaining: %d/%d\n", endProps.PartitionID, owner, lastUpdate, remaining, inf.eventsPerRound))
fmt.Fprintf(&stats, " [%s] o:%s (last: %s), remaining: %d/%d\n", endProps.PartitionID, owner, lastUpdate, remaining, inf.eventsPerRound)
}

return stats.String(), done == len(endPositions), nil
Expand Down
4 changes: 2 additions & 2 deletions sdk/messaging/azeventhubs/processor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -751,10 +751,10 @@ func printOwnerships(ctx context.Context, t *testing.T, cps azeventhubs.Checkpoi

for o, parts := range owners {
sort.Strings(parts)
sb.WriteString(fmt.Sprintf(" [%s (%d)] %s\n", o, len(parts), strings.Join(parts, ",")))
fmt.Fprintf(&sb, " [%s (%d)] %s\n", o, len(parts), strings.Join(parts, ","))
}

sb.WriteString(fmt.Sprintf(" Unowned (%d): %s\n", len(unowned), strings.Join(unowned, ",")))
fmt.Fprintf(&sb, " Unowned (%d): %s\n", len(unowned), strings.Join(unowned, ","))

sort.Strings(partitionIDs)

Expand Down