shibuya-kafka-adapter 0.6.0.0 → 0.7.0.0

raw patch · 4 files changed

+28/−3 lines, 4 filesdep ~shibuya-corePVP ok

version bump matches the API change (PVP)

Dependency ranges changed: shibuya-core

API changes (from Hackage documentation)

Files

• CHANGELOG.md +11/−0
• shibuya-kafka-adapter.cabal +3/−3
• src/Shibuya/Adapter/Kafka/Convert.hs +5/−0
• test/Shibuya/Adapter/Kafka/ConvertTest.hs +9/−0

@@ -1,5 +1,16 @@ # Changelog +## 0.7.0.0 — 2026-06-05++### Changed++- Require `shibuya-core ^>=0.7.0.0`. `Envelope` now carries a+  `headers :: Maybe Headers` field; `consumerRecordToEnvelope` populates it+  with every Kafka header verbatim (ordered, duplicates preserved) via+  `headersToList`. A record with no headers yields `Just []`. The parsed W3C+  trace headers continue to appear in `traceContext` and now also appear+  verbatim in `headers`.+ ## 0.6.0.0 — 2026-05-31  ### Breaking Changes

@@ -1,6 +1,6 @@ cabal-version:   3.12 name:            shibuya-kafka-adapter-version:         0.6.0.0+version:         0.7.0.0 synopsis:        Kafka adapter for the Shibuya queue processing framework description:   A Shibuya adapter that integrates with Apache Kafka via kafka-effectful@@ -61,7 +61,7 @@     , hw-kafka-client                        >=5.3       && <6     , hw-kafka-streamly                      ^>=0.2     , kafka-effectful                        ^>=0.3.0.0-    , shibuya-core                           ^>=0.6.0.0+    , shibuya-core                           ^>=0.7.0.0     , stm                                    ^>=2.5     , streamly                               ^>=0.11     , streamly-core                          ^>=0.3@@ -108,7 +108,7 @@     , kafka-effectful     , process     , random-    , shibuya-core                           ^>=0.6.0.0+    , shibuya-core                           ^>=0.7.0.0     , shibuya-kafka-adapter     , stm     , streamly

@@ -40,6 +40,10 @@ * @partition@: @Just (show partitionId)@ * @enqueuedAt@: converted from Kafka timestamp if available * @traceContext@: extracted from @traceparent@/@tracestate@ headers+* @headers@: every Kafka header verbatim (ordered, duplicates+  preserved) via @headersToList@; @Just []@ when the record carried+  no headers. The W3C trace headers appear here in addition to their+  parsed form in @traceContext@. * @attempt@: 'Nothing' (Kafka does not expose a redelivery counter) * @attributes@: kafka-typed OTel attributes (system, partition,   offset). The framework's @processOne@ adds these to its@@ -60,6 +64,7 @@         , partition = Just (Text.pack (show (unPartitionId cr.crPartition)))         , enqueuedAt = timestampToUTCTime cr.crTimestamp         , traceContext = extractTraceHeaders cr.crHeaders+        , headers = Just (headersToList cr.crHeaders)         , attempt = Nothing         , attributes = kafkaSpanAttributes cr.crPartition cr.crOffset         , payload = cr.crValue

@@ -87,6 +87,15 @@             cr = mkRecord (TopicName "t") (PartitionId 0) (Offset 0) NoTimestamp hdrs Nothing Nothing             env = consumerRecordToEnvelope cr         assertEqual "traceContext" (Just [("traceparent", "00-abc-def-01")]) env.traceContext+    , testCase "headers surfaced verbatim (order and duplicates preserved)" $ do+        let raw = [("schema-id", "42"), ("x-tag", "a"), ("x-tag", "b")]+            cr = mkRecord (TopicName "t") (PartitionId 0) (Offset 0) NoTimestamp (headersFromList raw) Nothing Nothing+            env = consumerRecordToEnvelope cr+        assertEqual "headers" (Just raw) env.headers+    , testCase "empty headers surface as Just []" $ do+        let cr = mkRecord (TopicName "t") (PartitionId 0) (Offset 0) NoTimestamp mempty Nothing Nothing+            env = consumerRecordToEnvelope cr+        assertEqual "headers" (Just []) env.headers     , testCase "attributes carry messaging.system=kafka" $ do         let cr = mkRecord (TopicName "orders") (PartitionId 2) (Offset 42) NoTimestamp mempty Nothing Nothing             env = consumerRecordToEnvelope cr