diff --git a/tests/certification/bindings/kafka/components/consumer1/kafka.yaml b/tests/certification/bindings/kafka/components/consumer1/kafka.yaml index 3d9a5c262..5b8ab3c34 100644 --- a/tests/certification/bindings/kafka/components/consumer1/kafka.yaml +++ b/tests/certification/bindings/kafka/components/consumer1/kafka.yaml @@ -1,24 +1,26 @@ -apiVersion: dapr.io/v1alpha1 -kind: Component -metadata: - name: messagebus -spec: - type: bindings.kafka - version: v1 - metadata: - - name: topics # Input binding topic - value: neworder - - name: publishTopic # Outpub binding topic - value: neworder - - name: brokers - value: localhost:19092,localhost:29092,localhost:39092 - - name: consumerGroup - value: kafkaCertification1 - - name: authType - value: "none" - - name: initialOffset - value: oldest - - name: backOffDuration - value: 50ms - - name: backOffDuration - value: 50ms +apiVersion: dapr.io/v1alpha1 +kind: Component +metadata: + name: messagebus +spec: + type: bindings.kafka + version: v1 + metadata: + - name: topics # Input binding topic + value: neworder + - name: publishTopic # Outpub binding topic + value: neworder + - name: consumeRetryEnabled # enable consumer retry + value: true + - name: brokers + value: localhost:19092,localhost:29092,localhost:39092 + - name: consumerGroup + value: kafkaCertification1 + - name: authType + value: "none" + - name: initialOffset + value: oldest + - name: backOffDuration + value: 50ms + - name: backOffDuration + value: 50ms diff --git a/tests/certification/bindings/kafka/components/consumer2/kafka.yaml b/tests/certification/bindings/kafka/components/consumer2/kafka.yaml index 99b6ca53a..ae472a2f3 100644 --- a/tests/certification/bindings/kafka/components/consumer2/kafka.yaml +++ b/tests/certification/bindings/kafka/components/consumer2/kafka.yaml @@ -10,6 +10,8 @@ spec: value: neworder - name: publishTopic # Outpub binding topic value: neworder + - name: consumeRetryEnabled # enable consumer retry + value: true - name: brokers value: localhost:19092,localhost:29092,localhost:39092 - name: consumerGroup