使用声明方式处理 pub/sub 事件时从应用程序返回不可重试的错误

Question

当我尝试使用 DAPR 发布/订阅使用主题时，出现这样的错误。看起来消息已成功消费，但之前记录了一个错误。无法确定根本原因。仅当我使用声明式订阅方式时才会出现此问题。如果我们改用 [Topic] 注释，则不会记录任何错误。我尝试使用不同的消息代理，例如rabbitMQ、redis、azure消息总线。情况对所有人来说都是一样的。 这是我使用的配置

pubsub.yml
# apiVersion: dapr.io/v1alpha1
# kind: Component
# metadata:
# name: pubsub
# spec:
# type: pubsub.redis
# version: v1
# metadata:
# - name: redisHost
# value: redis:6379
# - name: actorStateStore
# value: "true"
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: pubsub
spec:
type: pubsub.azure.servicebus.topics
version: v1
metadata:
  - name: connectionString
    value: 
Endpoint=sb://daprpocservicebus.servicebus.windows.net/;SharedAccessKeyName=RootManageShared AccessKey;SharedAccessKey=xxxxxxx

subscription.yml
apiVersion: dapr.io/v2alpha1
kind: Subscription
metadata:
name: pubsub
spec:
topic: weatherforecasttopic
routes:
default: /consume
pubsubname: pubsub
scopes:
  - daprpublisher
  - daprconsumer

我正在发布这样的值

await _daprClient.PublishEventAsync<WeatherForecast[]>(PubsubName, TopicNameOfWeatherForecast, forecast);

我被困在这里了。非常感谢任何帮助。预先感谢。

Answer 1

发现问题了。自从我添加了 daprpublisher 和 dapr 范围内的消费者服务。 /consume 端点仅在消费者中可用。

但仍然收到几个 404 错误：应用程序启动时 GET /dapr/config : 404、GET /dapr/subscribe : 404。需要进一步调查。