From 6f6c5b9c01e2c01c9786bfc6fa40cd20de7d650a Mon Sep 17 00:00:00 2001 From: Phil Kedy Date: Thu, 28 Oct 2021 12:05:46 -0400 Subject: [PATCH 1/2] Adding consumeRetryInterval setting to the Kafka pubsub settings table --- .../components-reference/supported-pubsub/setup-apache-kafka.md | 1 + 1 file changed, 1 insertion(+) 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 91a86b1cd..e029417b1 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 @@ -51,6 +51,7 @@ spec: | saslPassword | N | The SASL password used for authentication. Can be `secretKeyRef` to use a [secret reference]({{< ref component-secrets.md >}}). Only required if `authRequired` is set to `"true"`. | `""`, `"KeFg23!"` | initialOffset | N | The initial offset to use if no offset was previously committed. Should be "newest" or "oldest". Defaults to "newest". | `"oldest"` | maxMessageBytes | N | The maximum size in bytes allowed for a single Kafka message. Defaults to 1024. | `2048` +| consumeRetryInterval | N | The interval between retries when attempting to consume topics. Treats numbers without suffix as milliseconds. Defaults to 100ms. | `200ms` ## Per-call metadata fields From c1b648b40e496eea51faeff8ffa2dac3ae69aadf Mon Sep 17 00:00:00 2001 From: Phil Kedy Date: Thu, 28 Oct 2021 13:27:55 -0400 Subject: [PATCH 2/2] Adding consumeRetryInterval to example manifest --- .../components-reference/supported-pubsub/setup-apache-kafka.md | 2 ++ 1 file changed, 2 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 e029417b1..277b738bf 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 @@ -37,6 +37,8 @@ spec: key: saslPasswordSecret - name: maxMessageBytes # Optional. value: 1024 + - name: consumeRetryInterval # Optional. + value: 200ms ``` ## Spec metadata fields