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 | 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 a7968be25..9d24ea28f 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 @@ -310,6 +310,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. 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&metadata.partitionKey=key1 \ + -H "Content-Type: application/json" \ + -d '{ + "data": { + "message": "Hi" + } + }' +``` + ## Create a Kafka instance {{< tabs "Self-Hosted" "Kubernetes">}} 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 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