diff --git a/.github/workflows/benchmarks.yml b/.github/workflows/benchmarks.yml
new file mode 100644
index 00000000..31f4b2fa
--- /dev/null
+++ b/.github/workflows/benchmarks.yml
@@ -0,0 +1,46 @@
+name: Benchmarks
+
+on:
+  workflow_call:
+    inputs:
+      benchmark_package_path:
+        type: string
+        description: "Path to the directory containing the benchmarking package. Defaults to ."
+        default: "."
+      swift_package_arguments:
+        type: string
+        description: "Arguments to the switch package command invocation e.g. `--disable-sandbox`"
+      linux_5_9_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux 5.9 Swift version matrix job. Defaults to true."
+        default: true
+      linux_5_10_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux 5.10 Swift version matrix job. Defaults to true."
+        default: true
+      linux_6_0_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux 6.0 Swift version matrix job. Defaults to true."
+        default: true
+      linux_nightly_6_0_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux nightly 6.0 Swift version matrix job. Defaults to true."
+        default: true
+      linux_nightly_main_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux nightly main Swift version matrix job. Defaults to true."
+        default: true
+
+jobs:
+  benchmarks:
+    name: Benchmarks
+    # Workaround https://github.com/nektos/act/issues/1875
+    uses: ./.github/workflows/swift_matrix.yml
+    with:
+      name: "Benchmarks"
+      matrix_linux_command: "apt-get update -y -q && apt-get install -y -q libjemalloc-dev && apt-get -y install libsasl2-dev && swift package --package-path ${{ inputs.benchmark_package_path }} ${{ inputs.swift_package_arguments }} benchmark baseline check --check-absolute-path ${{ inputs.benchmark_package_path }}/Thresholds/${SWIFT_VERSION}/"
+      matrix_linux_5_9_enabled: ${{ inputs.linux_5_9_enabled }}
+      matrix_linux_5_10_enabled: ${{ inputs.linux_5_10_enabled }}
+      matrix_linux_6_0_enabled: ${{ inputs.linux_6_0_enabled }}
+      matrix_linux_nightly_6_0_enabled: ${{ inputs.linux_nightly_6_0_enabled }}
+      matrix_linux_nightly_main_enabled: ${{ inputs.linux_nightly_main_enabled }}
diff --git a/.github/workflows/cxx_interop.yml b/.github/workflows/cxx_interop.yml
new file mode 100644
index 00000000..fb8ef9d0
--- /dev/null
+++ b/.github/workflows/cxx_interop.yml
@@ -0,0 +1,39 @@
+name: Cxx interop
+
+on:
+  workflow_call:
+    inputs:
+      linux_5_9_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux 5.9 Swift version matrix job. Defaults to true."
+        default: true
+      linux_5_10_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux 5.10 Swift version matrix job. Defaults to true."
+        default: true
+      linux_6_0_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux 6.0 Swift version matrix job. Defaults to true."
+        default: true
+      linux_nightly_6_0_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux nightly 6.0 Swift version matrix job. Defaults to true."
+        default: true
+      linux_nightly_main_enabled:
+        type: boolean
+        description: "Boolean to enable the Linux nightly main Swift version matrix job. Defaults to true."
+        default: true
+
+jobs:
+  cxx-interop:
+    name: Cxx interop
+    # Workaround https://github.com/nektos/act/issues/1875
+    uses: ./.github/workflows/swift_matrix.yml
+    with:
+      name: "Cxx interop"
+      matrix_linux_command: "apt-get update -y -q && apt-get install -y -q jq && apt-get -y install libsasl2-dev && curl -s  https://raw.githubusercontent.com/apple/swift-nio/main/scripts/check-cxx-interop-compatibility.sh | bash"
+      matrix_linux_5_9_enabled: ${{ inputs.linux_5_9_enabled }}
+      matrix_linux_5_10_enabled: ${{ inputs.linux_5_10_enabled }}
+      matrix_linux_6_0_enabled: ${{ inputs.linux_6_0_enabled }}
+      matrix_linux_nightly_6_0_enabled: ${{ inputs.linux_nightly_6_0_enabled }}
+      matrix_linux_nightly_main_enabled: ${{ inputs.linux_nightly_main_enabled }}
diff --git a/.github/workflows/main.yml b/.github/workflows/main.yml
index b2f403c3..4a62c521 100644
--- a/.github/workflows/main.yml
+++ b/.github/workflows/main.yml
@@ -9,6 +9,7 @@ on:
 jobs:
   unit-tests:
     name: Unit tests
+    # Workaround https://github.com/nektos/act/issues/1875
     uses: ./.github/workflows/unit_tests.yml
     with:
       linux_5_9_arguments_override: "--explicit-target-dependency-import-check error -Xswiftc -strict-concurrency=complete"
@@ -16,3 +17,15 @@ jobs:
       linux_6_0_arguments_override: "--explicit-target-dependency-import-check error"
       linux_nightly_6_0_arguments_override: "--explicit-target-dependency-import-check error"
       linux_nightly_main_arguments_override: "--explicit-target-dependency-import-check error"
+
+  benchmarks:
+    name: Benchmarks
+    # Workaround https://github.com/nektos/act/issues/1875
+    uses: ./.github/workflows/benchmarks.yml@main
+    with:
+      benchmark_package_path: "Benchmarks"
+
+  cxx-interop:
+    name: Cxx interop
+    # Workaround https://github.com/nektos/act/issues/1875
+    uses: ./.github/workflows/cxx_interop.yml
diff --git a/.github/workflows/pull_request.yml b/.github/workflows/pull_request.yml
index 2c6a87a4..dc4f525c 100644
--- a/.github/workflows/pull_request.yml
+++ b/.github/workflows/pull_request.yml
@@ -23,17 +23,14 @@ jobs:
       linux_nightly_6_0_arguments_override: "--explicit-target-dependency-import-check error"
       linux_nightly_main_arguments_override: "--explicit-target-dependency-import-check error"
 
+  benchmarks:
+    name: Benchmarks
+    # Workaround https://github.com/nektos/act/issues/1875
+    uses: ./.github/workflows/benchmarks.yml
+    with:
+      benchmark_package_path: "Benchmarks"
+
   cxx-interop:
     name: Cxx interop
-    uses: apple/swift-nio/.github/workflows/swift_matrix.yml@main
-    with:
-      name: "Cxx interop"
-      matrix_linux_command: "apt-get update -y -q && apt-get install -y -q jq && apt-get -y install libsasl2-dev && curl -s https://raw.githubusercontent.com/apple/swift-nio/main/scripts/check-cxx-interop-compatibility.sh | bash"
-      matrix_linux_5_9_enabled: true
-      matrix_linux_5_10_enabled: true
-      matrix_linux_6_0_enabled: true
-      matrix_linux_nightly_6_0_enabled: true
-      matrix_linux_nightly_main_enabled: true
-      matrix_windows_6_0_enabled: false
-      matrix_windows_nightly_6_0_enabled: false
-      matrix_windows_nightly_main_enabled: false
+    # Workaround https://github.com/nektos/act/issues/1875
+    uses: ./.github/workflows/cxx_interop.yml
diff --git a/.github/workflows/swift_matrix.yml b/.github/workflows/swift_matrix.yml
new file mode 100644
index 00000000..612718de
--- /dev/null
+++ b/.github/workflows/swift_matrix.yml
@@ -0,0 +1,133 @@
+name: Matrix
+
+on:
+  workflow_call:
+    inputs:
+      name:
+        type: string
+        description: "The name of the workflow used for the concurrency group."
+        required: true
+      matrix_linux_command:
+        type: string
+        description: "The command of the current Swift version linux matrix job to execute."
+        required: true
+      matrix_linux_5_9_enabled:
+        type: boolean
+        description: "Boolean to enable the 5.9 Swift version matrix job. Defaults to true."
+        default: true
+      matrix_linux_5_9_container_image:
+        type: string
+        description: "Container image for the 5.9 Swift version matrix job. Defaults to matching Swift Ubuntu image."
+        default: "swift:5.9-jammy"
+      matrix_linux_5_9_command_override:
+        type: string
+        description: "The command of the 5.9 Swift version linux matrix job to execute."
+      matrix_linux_5_10_enabled:
+        type: boolean
+        description: "Boolean to enable the 5.10 Swift version matrix job. Defaults to true."
+        default: true
+      matrix_linux_5_10_container_image:
+        type: string
+        description: "Container image for the 5.10 Swift version matrix job. Defaults to matching Swift Ubuntu image."
+        default: "swift:5.10-jammy"
+      matrix_linux_5_10_command_override:
+        type: string
+        description: "The command of the 5.10 Swift version linux matrix job to execute."
+      matrix_linux_6_0_enabled:
+        type: boolean
+        description: "Boolean to enable the 6.0 Swift version matrix job. Defaults to true."
+        default: true
+      matrix_linux_6_0_container_image:
+        type: string
+        description: "Container image for the 6.0 Swift version matrix job. Defaults to matching Swift Ubuntu image."
+        default: "swift:6.0-jammy"
+      matrix_linux_6_0_command_override:
+        type: string
+        description: "The command of the 6.0 Swift version linux matrix job to execute."
+      matrix_linux_nightly_6_0_enabled:
+        type: boolean
+        description: "Boolean to enable the nightly 6.0 Swift version matrix job. Defaults to true."
+        default: true
+      matrix_linux_nightly_6_0_container_image:
+        type: string
+        description: "Container image for the nightly 6.0 Swift version matrix job. Defaults to matching Swift Ubuntu image."
+        default: "swiftlang/swift:nightly-6.0-jammy"
+      matrix_linux_nightly_6_0_command_override:
+        type: string
+        description: "The command of the nightly 6.0 Swift version linux matrix job to execute."
+      matrix_linux_nightly_main_enabled:
+        type: boolean
+        description: "Boolean to enable the nightly main Swift version matrix job. Defaults to true."
+        default: true
+      matrix_linux_nightly_main_container_image:
+        type: string
+        description: "Container image for the nightly main Swift version matrix job. Defaults to matching Swift Ubuntu image."
+        default: "swiftlang/swift:nightly-main-jammy"
+      matrix_linux_nightly_main_command_override:
+        type: string
+        description: "The command of the nightly main Swift version linux matrix job to execute."
+
+# We are cancelling previously triggered workflow runs
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}-${{ inputs.name }}
+  cancel-in-progress: true
+
+jobs:
+  linux:
+    name: Linux (${{ matrix.swift.swift_version }})
+    runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        # We are specifying only the major and minor of the docker images to automatically pick up the latest patch release
+        swift:
+          - image: ${{ inputs.matrix_linux_5_9_container_image }}
+            swift_version: "5.9"
+            enabled: ${{ inputs.matrix_linux_5_9_enabled }}
+          - image: ${{ inputs.matrix_linux_5_10_container_image }}
+            swift_version: "5.10"
+            enabled: ${{ inputs.matrix_linux_5_10_enabled }}
+          - image: ${{ inputs.matrix_linux_6_0_container_image }}
+            swift_version: "6.0"
+            enabled: ${{ inputs.matrix_linux_6_0_enabled }}
+          - image: ${{ inputs.matrix_linux_nightly_6_0_container_image }}
+            swift_version: "nightly-6.0"
+            enabled: ${{ inputs.matrix_linux_nightly_6_0_enabled }}
+          - image: ${{ inputs.matrix_linux_nightly_main_container_image }}
+            swift_version: "nightly-main"
+            enabled: ${{ inputs.matrix_linux_nightly_main_enabled }}
+    container:
+      image: ${{ matrix.swift.image }}
+    steps:
+      - name: Checkout repository
+        if: ${{ matrix.swift.enabled }}
+        uses: actions/checkout@v4
+        with:
+          persist-credentials: false
+          submodules: true
+      - name: Mark the workspace as safe
+        if: ${{ matrix.swift.enabled }}
+        # https://github.com/actions/checkout/issues/766
+        run: git config --global --add safe.directory ${GITHUB_WORKSPACE}
+      - name: Run matrix job
+        if: ${{ matrix.swift.enabled }}
+        env:
+          SWIFT_VERSION: ${{ matrix.swift.swift_version }}
+          COMMAND: ${{ inputs.matrix_linux_command }}
+          COMMAND_OVERRIDE_5_9: ${{ inputs.matrix_linux_5_9_command_override }}
+          COMMAND_OVERRIDE_5_10: ${{ inputs.matrix_linux_5_10_command_override }}
+          COMMAND_OVERRIDE_6_0: ${{ inputs.matrix_linux_6_0_command_override }}
+          COMMAND_OVERRIDE_NIGHTLY_6_0: ${{ inputs.matrix_linux_nightly_6_0_command_override }}
+          COMMAND_OVERRIDE_NIGHTLY_MAIN: ${{ inputs.matrix_linux_nightly_main_command_override }}
+        run: |
+          apt-get -qq update && apt-get -qq -y install curl && apt-get -y install libsasl2-dev
+          curl -s https://raw.githubusercontent.com/apple/swift-nio/main/scripts/check-matrix-job.sh | bash
+    services:
+      zookeeper:
+        image: ubuntu/zookeeper
+      kafka:
+        image: ubuntu/kafka
+        env:
+          ZOOKEEPER_HOST: zookeeper
+    env:
+      KAFKA_HOST: kafka
diff --git a/.github/workflows/unit_tests.yml b/.github/workflows/unit_tests.yml
index 3300a33b..7a3d2026 100644
--- a/.github/workflows/unit_tests.yml
+++ b/.github/workflows/unit_tests.yml
@@ -47,59 +47,18 @@ on:
 jobs:
   unit-tests:
     name: Unit tests
-    runs-on: ubuntu-latest
-    strategy:
-      fail-fast: false
-      matrix:
-        # We are specifying only the major and minor of the docker images to automatically pick up the latest patch release
-        swift:
-          - image: "swift:5.9-jammy"
-            swift_version: "5.9"
-            enabled: ${{ inputs.linux_5_9_enabled }}
-          - image: "swift:5.10-jammy"
-            swift_version: "5.10"
-            enabled: ${{ inputs.linux_5_10_enabled }}
-          - image: "swift:6.0-jammy"
-            swift_version: "6.0"
-            enabled: ${{ inputs.linux_6_0_enabled }}
-          - image: "swiftlang/swift:nightly-6.0-jammy"
-            swift_version: "nightly-6.0"
-            enabled: ${{ inputs.linux_nightly_6_0_enabled }}
-          - image: "swiftlang/swift:nightly-main-jammy"
-            swift_version: "nightly-main"
-            enabled: ${{ inputs.linux_nightly_main_enabled }}
-    steps:
-      - name: Checkout repository
-        if: ${{ matrix.swift.enabled }}
-        uses: actions/checkout@v4
-        with:
-          persist-credentials: false
-          submodules: true
-      - name: Mark the workspace as safe
-        if: ${{ matrix.swift.enabled }}
-        # https://github.com/actions/checkout/issues/766
-        run: git config --global --add safe.directory ${GITHUB_WORKSPACE}
-      - name: Run matrix job
-        if: ${{ matrix.swift.enabled }}
-        env:
-          SWIFT_VERSION: ${{ matrix.swift.swift_version }}
-          COMMAND: "swift test"
-          COMMAND_OVERRIDE_5_9: "swift test ${{ inputs.linux_5_9_arguments_override }}"
-          COMMAND_OVERRIDE_5_10: "swift test ${{ inputs.linux_5_10_arguments_override }}"
-          COMMAND_OVERRIDE_6_0: "swift test ${{ inputs.linux_6_0_arguments_override }}"
-          COMMAND_OVERRIDE_NIGHTLY_6_0: "swift test ${{ inputs.linux_nightly_6_0_arguments_override }}"
-          COMMAND_OVERRIDE_NIGHTLY_MAIN: "swift test ${{ inputs.linux_nightly_main_arguments_override }}"
-        run: |
-          apt-get -qq update && apt-get -qq -y install curl && apt-get -y install libsasl2-dev
-          curl -s https://raw.githubusercontent.com/apple/swift-nio/main/scripts/check-matrix-job.sh | bash
-    container:
-      image: ${{ matrix.swift.image }}
-    services:
-      zookeeper:
-        image: ubuntu/zookeeper
-      kafka:
-        image: ubuntu/kafka
-        env:
-          ZOOKEEPER_HOST: zookeeper
-    env:
-      KAFKA_HOST: kafka
+    # Workaround https://github.com/nektos/act/issues/1875
+    uses: ./.github/workflows/swift_matrix.yml
+    with:
+      name: "Unit tests"
+      matrix_linux_command: "swift test"
+      matrix_linux_5_9_enabled: ${{ inputs.linux_5_9_enabled }}
+      matrix_linux_5_9_command_override: "swift test ${{ inputs.linux_5_9_arguments_override }}"
+      matrix_linux_5_10_enabled: ${{ inputs.linux_5_10_enabled }}
+      matrix_linux_5_10_command_override: "swift test ${{ inputs.linux_5_10_arguments_override }}"
+      matrix_linux_6_0_enabled: ${{ inputs.linux_6_0_enabled }}
+      matrix_linux_6_0_command_override: "swift test ${{ inputs.linux_6_0_arguments_override }}"
+      matrix_linux_nightly_6_0_enabled: ${{ inputs.linux_nightly_6_0_enabled }}
+      matrix_linux_nightly_6_0_command_override: "swift test ${{ inputs.linux_nightly_6_0_arguments_override }}"
+      matrix_linux_nightly_main_enabled: ${{ inputs.linux_nightly_main_enabled }}
+      matrix_linux_nightly_main_command_override: "swift test ${{ inputs.linux_nightly_main_arguments_override }}"
diff --git a/Benchmarks/Package.swift b/Benchmarks/Package.swift
index 4301f8de..cc8f15b2 100644
--- a/Benchmarks/Package.swift
+++ b/Benchmarks/Package.swift
@@ -1,4 +1,4 @@
-// swift-tools-version: 5.7
+// swift-tools-version: 5.9
 //===----------------------------------------------------------------------===//
 //
 // This source file is part of the swift-kafka-client open source project
diff --git a/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..210167a5
--- /dev/null
+++ b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 77266944,
+  "cpuTotal" : 200000000,
+  "objectAllocCount" : 5549,
+  "releaseCount" : 15168,
+  "retainCount" : 7108,
+  "retainReleaseDelta" : 2511,
+  "throughput" : 2,
+  "wallClock" : 695307500
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..0e0dcd23
--- /dev/null
+++ b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,3 @@
+{
+
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..2be930a7
--- /dev/null
+++ b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 47382528,
+  "cpuTotal" : 10000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 48,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 30,
+  "throughput" : 2,
+  "wallClock" : 640572501
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..a4bb5ea5
--- /dev/null
+++ b/Benchmarks/Thresholds/5.10/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 44204031,
+  "cpuTotal" : 80000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 48,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 30,
+  "throughput" : 3,
+  "wallClock" : 320339967
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..f3f1b180
--- /dev/null
+++ b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 88211455,
+  "cpuTotal" : 40009727,
+  "objectAllocCount" : 3471,
+  "releaseCount" : 9175,
+  "retainCount" : 4435,
+  "retainReleaseDelta" : 1267,
+  "throughput" : 9,
+  "wallClock" : 130154495
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..803cb779
--- /dev/null
+++ b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 73924608,
+  "cpuTotal" : 200000000,
+  "objectAllocCount" : 6039,
+  "releaseCount" : 14939,
+  "retainCount" : 6695,
+  "retainReleaseDelta" : 2205,
+  "throughput" : 2,
+  "wallClock" : 646714708
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..c1208ead
--- /dev/null
+++ b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 47579136,
+  "cpuTotal" : 20000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 48,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 30,
+  "throughput" : 2,
+  "wallClock" : 648354417
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..877d1f0e
--- /dev/null
+++ b/Benchmarks/Thresholds/5.9/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 42926080,
+  "cpuTotal" : 90000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 44,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 26,
+  "throughput" : 1,
+  "wallClock" : 881145958
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..e9cdc8b8
--- /dev/null
+++ b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 81592320,
+  "cpuTotal" : 200000000,
+  "objectAllocCount" : 4609,
+  "releaseCount" : 16389,
+  "retainCount" : 9217,
+  "retainReleaseDelta" : 2563,
+  "throughput" : 2,
+  "wallClock" : 709379209
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..f4eb9e30
--- /dev/null
+++ b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 78512128,
+  "cpuTotal" : 200000000,
+  "objectAllocCount" : 5439,
+  "releaseCount" : 18714,
+  "retainCount" : 10871,
+  "retainReleaseDelta" : 2404,
+  "throughput" : 2,
+  "wallClock" : 657556084
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..40f3f3fb
--- /dev/null
+++ b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 48431104,
+  "cpuTotal" : 30000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 40,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 22,
+  "throughput" : 2,
+  "wallClock" : 640575375
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..949815b3
--- /dev/null
+++ b/Benchmarks/Thresholds/6.0/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 43450368,
+  "cpuTotal" : 90000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 44,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 26,
+  "throughput" : 1,
+  "wallClock" : 874572167
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..b26180ee
--- /dev/null
+++ b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 79691776,
+  "cpuTotal" : 170000000,
+  "objectAllocCount" : 4593,
+  "releaseCount" : 16334,
+  "retainCount" : 9187,
+  "retainReleaseDelta" : 2554,
+  "throughput" : 2,
+  "wallClock" : 698023125
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..e61770ca
--- /dev/null
+++ b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.SwiftKafkaConsumer_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 72613888,
+  "cpuTotal" : 150000000,
+  "objectAllocCount" : 5459,
+  "releaseCount" : 18789,
+  "retainCount" : 10914,
+  "retainReleaseDelta" : 2420,
+  "throughput" : 2,
+  "wallClock" : 647447376
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
new file mode 100644
index 00000000..233f2340
--- /dev/null
+++ b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.librdkafka_basic_consumer_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 48037888,
+  "cpuTotal" : 20000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 44,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 26,
+  "throughput" : 2,
+  "wallClock" : 642639208
+}
\ No newline at end of file
diff --git a/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
new file mode 100644
index 00000000..6a90ed0e
--- /dev/null
+++ b/Benchmarks/Thresholds/nightly-6.0/SwiftKafkaConsumerBenchmarks.librdkafka_with_offset_commit_messages_1000.p90.json
@@ -0,0 +1,10 @@
+{
+  "allocatedResidentMemory" : 50200576,
+  "cpuTotal" : 90000000,
+  "objectAllocCount" : 16,
+  "releaseCount" : 52,
+  "retainCount" : 2,
+  "retainReleaseDelta" : 34,
+  "throughput" : 1,
+  "wallClock" : 875615959
+}
\ No newline at end of file
diff --git a/Sources/Kafka/ForTesting/RDKafkaClient+Topic.swift b/Sources/Kafka/ForTesting/RDKafkaClient+Topic.swift
index 2eb7b153..8c393812 100644
--- a/Sources/Kafka/ForTesting/RDKafkaClient+Topic.swift
+++ b/Sources/Kafka/ForTesting/RDKafkaClient+Topic.swift
@@ -59,7 +59,7 @@ extension RDKafkaClient {
             )
 
             guard let resultEvent = rd_kafka_queue_poll(resultQueue, timeout) else {
-                throw KafkaError.topicCreation(reason: "No CreateTopics result after 10s timeout")
+                throw KafkaError.topicCreation(reason: "No CreateTopics result after \(timeout)ms timeout")
             }
             defer { rd_kafka_event_destroy(resultEvent) }
 
diff --git a/Sources/Kafka/KafkaConsumer.swift b/Sources/Kafka/KafkaConsumer.swift
index bd3f5542..5c917bbb 100644
--- a/Sources/Kafka/KafkaConsumer.swift
+++ b/Sources/Kafka/KafkaConsumer.swift
@@ -140,7 +140,7 @@ public struct KafkaConsumerMessages: Sendable, AsyncSequence {
 
 // MARK: - KafkaConsumer
 
-/// A ``KafkaConsumer `` can be used to consume messages from a Kafka cluster.
+/// A ``KafkaConsumer`` can be used to consume messages from a Kafka cluster.
 public final class KafkaConsumer: Sendable, Service {
     /// The configuration object of the consumer client.
     private let configuration: KafkaConsumerConfiguration
diff --git a/dev/update-benchmark-thresholds.sh b/dev/update-benchmark-thresholds.sh
index be8bf886..e960b7eb 100755
--- a/dev/update-benchmark-thresholds.sh
+++ b/dev/update-benchmark-thresholds.sh
@@ -16,13 +16,13 @@
 set -eu
 set -o pipefail
 
-here="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
+here="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
 target_repo=${2-"$here/.."}
 
-for f in 57 58 59 510 -nightly; do
+for f in 59 510 60 nightly-6.0 main; do
     echo "swift$f"
 
-    docker_file=$(if [[ "$f" == "-nightly" ]]; then f=main; fi && ls "$target_repo/docker/docker-compose."*"$f"*".yaml")
+    docker_file=$(ls "$target_repo/docker/docker-compose."*"$f"*".yaml")
 
     docker-compose -f docker/docker-compose.yaml -f "$docker_file" run update-benchmark-baseline
 done
diff --git a/docker/docker-compose.2204.510.yaml b/docker/docker-compose.2204.510.yaml
index 17acb143..269e904f 100644
--- a/docker/docker-compose.2204.510.yaml
+++ b/docker/docker-compose.2204.510.yaml
@@ -1,12 +1,10 @@
-version: "3"
-
+name: swift-kafka-client-22.04-5.10
 services:
-
   runtime-setup:
     image: swift-kafka-client:22.04-5.10
     build:
       args:
-        base_image: "swiftlang/swift:nightly-5.10-jammy"
+        base_image: "swift:5.10-jammy"
 
   build:
     image: swift-kafka-client:22.04-5.10
diff --git a/docker/docker-compose.2204.57.yaml b/docker/docker-compose.2204.57.yaml
deleted file mode 100644
index a465a610..00000000
--- a/docker/docker-compose.2204.57.yaml
+++ /dev/null
@@ -1,29 +0,0 @@
-version: "3"
-
-services:
-
-  runtime-setup:
-    image: swift-kafka-client:22.04-5.7
-    build:
-      args:
-        ubuntu_version: "jammy"
-        swift_version: "5.7"
-
-  build:
-    image: swift-kafka-client:22.04-5.7
-
-  test:
-    image: swift-kafka-client:22.04-5.7
-    environment:
-      - SWIFT_VERSION=5.7
-      - WARN_AS_ERROR_ARG=-Xswiftc -warnings-as-errors
-      - STRICT_CONCURRENCY_ARG=-Xswiftc -strict-concurrency=complete
-      # - SANITIZER_ARG=--sanitize=thread # TSan broken still
-
-  update-benchmark-baseline:
-    image: swift-kafka-client:22.04-5.7
-    environment:
-      - SWIFT_VERSION=5.7
-
-  shell:
-    image: swift-kafka-client:22.04-5.7
diff --git a/docker/docker-compose.2204.59.yaml b/docker/docker-compose.2204.59.yaml
index 8d9cf29d..d3738796 100644
--- a/docker/docker-compose.2204.59.yaml
+++ b/docker/docker-compose.2204.59.yaml
@@ -1,13 +1,10 @@
-version: "3"
-
+name: swift-kafka-client-22.04-5.9
 services:
-
   runtime-setup:
     image: swift-kafka-client:22.04-5.9
     build:
       args:
-        ubuntu_version: "jammy"
-        swift_version: "5.9"
+        base_image: "swift:5.9-jammy"
 
   build:
     image: swift-kafka-client:22.04-5.9
diff --git a/docker/docker-compose.2204.58.yaml b/docker/docker-compose.2204.60.yaml
similarity index 55%
rename from docker/docker-compose.2204.58.yaml
rename to docker/docker-compose.2204.60.yaml
index 47b02679..6ffe45ea 100644
--- a/docker/docker-compose.2204.58.yaml
+++ b/docker/docker-compose.2204.60.yaml
@@ -1,30 +1,26 @@
-version: "3"
-
+name: swift-kafka-client-22.04-6.0
 services:
-
   runtime-setup:
-    image: swift-kafka-client:22.04-5.8
+    image: swift-kafka-client:22.04-6.0
     build:
       args:
-        ubuntu_version: "jammy"
-        swift_version: "5.8"
+        base_image: "swift:6.0-jammy"
 
   build:
-    image: swift-kafka-client:22.04-5.8
+    image: swift-kafka-client:22.04-6.0
 
   test:
-    image: swift-kafka-client:22.04-5.8
+    image: swift-kafka-client:22.04-6.0
     environment:
-      - SWIFT_VERSION=5.8
       - WARN_AS_ERROR_ARG=-Xswiftc -warnings-as-errors
       - IMPORT_CHECK_ARG=--explicit-target-dependency-import-check error
       - STRICT_CONCURRENCY_ARG=-Xswiftc -strict-concurrency=complete
       # - SANITIZER_ARG=--sanitize=thread # TSan broken still
 
   update-benchmark-baseline:
-    image: swift-kafka-client:22.04-5.8
+    image: swift-kafka-client:22.04-6.0
     environment:
-      - SWIFT_VERSION=5.8
+      - SWIFT_VERSION=6.0
 
   shell:
-    image: swift-kafka-client:22.04-5.8
+    image: swift-kafka-client:22.04-6.0
diff --git a/docker/docker-compose.2204.main.yaml b/docker/docker-compose.2204.main.yaml
index acac1a54..b6e77a2b 100644
--- a/docker/docker-compose.2204.main.yaml
+++ b/docker/docker-compose.2204.main.yaml
@@ -1,7 +1,5 @@
-version: "3"
-
+name: swift-kafka-client-22.04-main
 services:
-
   runtime-setup:
     image: swift-kafka-client:22.04-main
     build:
diff --git a/docker/docker-compose.2204.nightly-6.0.yaml b/docker/docker-compose.2204.nightly-6.0.yaml
new file mode 100644
index 00000000..65c964bb
--- /dev/null
+++ b/docker/docker-compose.2204.nightly-6.0.yaml
@@ -0,0 +1,26 @@
+name: swift-kafka-client-22.04-nightly-6.0
+services:
+  runtime-setup:
+    image: swift-kafka-client:22.04-nightly-6.0
+    build:
+      args:
+        base_image: "swiftlang/swift:nightly-6.0-jammy"
+
+  build:
+    image: swift-kafka-client:22.04-nightly-6.0
+
+  test:
+    image: swift-kafka-client:22.04-nightly-6.0
+    environment:
+      - WARN_AS_ERROR_ARG=-Xswiftc -warnings-as-errors
+      - IMPORT_CHECK_ARG=--explicit-target-dependency-import-check error
+      - STRICT_CONCURRENCY_ARG=-Xswiftc -strict-concurrency=complete
+      # - SANITIZER_ARG=--sanitize=thread # TSan broken still
+
+  update-benchmark-baseline:
+    image: swift-kafka-client:22.04-nightly-6.0
+    environment:
+      - SWIFT_VERSION=nightly-6.0
+
+  shell:
+    image: swift-kafka-client:22.04-nightly-6.0
diff --git a/docker/docker-compose.yaml b/docker/docker-compose.yaml
index 10f1665c..85585706 100644
--- a/docker/docker-compose.yaml
+++ b/docker/docker-compose.yaml
@@ -1,9 +1,7 @@
 # this file is not designed to be run directly
 # instead, use the docker-compose.<os>.<swift> files
-# eg docker-compose -f docker/docker-compose.yaml -f docker/docker-compose.2204.57.yaml run test
-version: "3.9"
+# eg docker-compose -f docker/docker-compose.yaml -f docker/docker-compose.2204.59.yaml run test
 services:
-
   zookeeper:
     image: ubuntu/zookeeper
 
@@ -44,17 +42,17 @@ services:
   build:
     <<: *common
     environment: []
-    command: /bin/bash -cl "swift build"
+    command: /bin/bash -cl "swift build --scratch-path .build/$${SWIFT_VERSION-}/"
 
   test:
     <<: *common
     depends_on: [kafka, runtime-setup]
     environment:
-      SWIFT_VERSION: 5.7
+      SWIFT_VERSION: 5.9
       KAFKA_HOST: kafka
     command: >
       /bin/bash -xcl "
-        swift build --build-tests $${SANITIZER_ARG-} && \
+        swift build --scratch-path .build/$${SWIFT_VERSION-}/ --build-tests $${SANITIZER_ARG-} && \
         swift $${SWIFT_TEST_VERB-test} $${WARN_AS_ERROR_ARG-} $${SANITIZER_ARG-} $${IMPORT_CHECK_ARG-} $${STRICT_CONCURRENCY_ARG-}
       "
 
@@ -65,7 +63,7 @@ services:
       KAFKA_HOST: kafka
     command: >
       /bin/bash -xcl "
-        cd Benchmarks && swift package --disable-sandbox benchmark
+        cd Benchmarks && swift package --disable-sandbox --scratch-path .build/$${SWIFT_VERSION-}/ benchmark
       "
 
   update-benchmark-baseline: