From 6079c0e34bf45e917a9e7b7c4370c861ad2d0f11 Mon Sep 17 00:00:00 2001 From: Phil Kedy Date: Wed, 5 Jan 2022 10:18:08 -0500 Subject: [PATCH 1/5] Docs tweak for #1408 / #1409: Kafka PubSub using metadata as headers Signed-off-by: Phil Kedy --- .../supported-pubsub/setup-apache-kafka.md | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md index e0e4167c9..c44505880 100644 --- a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md +++ b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md @@ -136,6 +136,20 @@ curl -X POST http://localhost:3500/v1.0/publish/myKafka/myTopic?metadata.partiti }' ``` +### Message headers + +All other metadata key/value pairs (that are not `partitionKey`) are set as headers in the Kafka message. For example, here is an example setting a `correlationId` for the message. + +```shell +curl -X POST http://localhost:3500/v1.0/publish/myKafka/myTopic?metadata.correlationId=myCorrelationID \ + -H "Content-Type: application/json" \ + -d '{ + "data": { + "message": "Hi" + } + }' +``` + ## Create a Kafka instance {{< tabs "Self-Hosted" "Kubernetes">}} From 162a07e1268478846d6c42ab60f521fcf9d24a29 Mon Sep 17 00:00:00 2001 From: Phil Kedy Date: Fri, 21 Jan 2022 10:35:28 -0500 Subject: [PATCH 2/5] Comments per PR Signed-off-by: Phil Kedy --- .../supported-pubsub/setup-apache-kafka.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md index c44505880..051f6a473 100644 --- a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md +++ b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-apache-kafka.md @@ -138,10 +138,10 @@ curl -X POST http://localhost:3500/v1.0/publish/myKafka/myTopic?metadata.partiti ### Message headers -All other metadata key/value pairs (that are not `partitionKey`) are set as headers in the Kafka message. For example, here is an example setting a `correlationId` for the message. +All other metadata key/value pairs (that are not `partitionKey`) are set as headers in the Kafka message. Here is an example setting a `correlationId` for the message. ```shell -curl -X POST http://localhost:3500/v1.0/publish/myKafka/myTopic?metadata.correlationId=myCorrelationID \ +curl -X POST http://localhost:3500/v1.0/publish/myKafka/myTopic?metadata.correlationId=myCorrelationID&metadata.partitionKey=key1 \ -H "Content-Type: application/json" \ -d '{ "data": { From d82884b83d7b06f496271ac52027342ccc3dc73d Mon Sep 17 00:00:00 2001 From: Nick Greenfield Date: Fri, 21 Jan 2022 12:06:02 -0800 Subject: [PATCH 3/5] Update Azure binding components from Alpha to Beta Signed-off-by: Nick Greenfield --- .../components-reference/supported-bindings/_index.md | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/daprdocs/content/en/reference/components-reference/supported-bindings/_index.md b/daprdocs/content/en/reference/components-reference/supported-bindings/_index.md index 2c0e2625e..ea3cd2adb 100644 --- a/daprdocs/content/en/reference/components-reference/supported-bindings/_index.md +++ b/daprdocs/content/en/reference/components-reference/supported-bindings/_index.md @@ -74,12 +74,12 @@ Table captions: | Name | Input
Binding | Output
Binding | Status | Component version | Since | |------|:----------------:|:-----------------:|--------| --------- | ---------- | -| [Azure Blob Storage]({{< ref blobstorage.md >}}) | | ✅ | Alpha | v1 | 1.0 | -| [Azure CosmosDB]({{< ref cosmosdb.md >}}) | | ✅ | Alpha | v1 | 1.0 | +| [Azure Blob Storage]({{< ref blobstorage.md >}}) | | ✅ | Beta | v1 | 1.0 | +| [Azure CosmosDB]({{< ref cosmosdb.md >}}) | | ✅ | Beta | v1 | 1.0 | | [Azure CosmosDBGremlinAPI]({{< ref cosmosdbgremlinapi.md >}}) | | ✅ | Alpha | v1 | 1.5 | | [Azure Event Grid]({{< ref eventgrid.md >}}) | ✅ | ✅ | Alpha | v1 | 1.0 | -| [Azure Event Hubs]({{< ref eventhubs.md >}}) | ✅ | ✅ | Alpha | v1 | 1.0 | -| [Azure Service Bus Queues]({{< ref servicebusqueues.md >}}) | ✅ | ✅ | Alpha | v1 | 1.0 | +| [Azure Event Hubs]({{< ref eventhubs.md >}}) | ✅ | ✅ | Beta | v1 | 1.0 | +| [Azure Service Bus Queues]({{< ref servicebusqueues.md >}}) | ✅ | ✅ | Beta | v1 | 1.0 | | [Azure SignalR]({{< ref signalr.md >}}) | | ✅ | Alpha | v1 | 1.0 | | [Azure Storage Queues]({{< ref storagequeues.md >}}) | ✅ | ✅ | Stable| v1 | 1.0 | From 360659b258f28e60c9160f0b91e4c617324d1e93 Mon Sep 17 00:00:00 2001 From: Nick Greenfield Date: Fri, 21 Jan 2022 13:11:01 -0800 Subject: [PATCH 4/5] Update Python SDK repo submodule to include state query api and config api docs Signed-off-by: Nick Greenfield --- sdkdocs/python | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdkdocs/python b/sdkdocs/python index 058cfcf4d..6d7d94007 160000 --- a/sdkdocs/python +++ b/sdkdocs/python @@ -1 +1 @@ -Subproject commit 058cfcf4d603823c5916bb5ae533bb9f5bb862fd +Subproject commit 6d7d9400736d2c58901c7b49f666a159f987e789 From 34707c18dc6fd7ec85da5d23eb100086956fdd42 Mon Sep 17 00:00:00 2001 From: Hal Spang Date: Fri, 21 Jan 2022 13:30:06 -0800 Subject: [PATCH 5/5] Updated .NET SDK Docs to include Configuration API Signed-off-by: Hal Spang --- sdkdocs/dotnet | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdkdocs/dotnet b/sdkdocs/dotnet index 2ffbb113e..20ef37382 160000 --- a/sdkdocs/dotnet +++ b/sdkdocs/dotnet @@ -1 +1 @@ -Subproject commit 2ffbb113e7b5186a96ee38426a2c08526e83b0e0 +Subproject commit 20ef37382cf3e3e4ef74475c72772733abb21922