SpringCloudStream：不同消息类型的使用者
使用StreamBridge，我将包含两种不同类型的对象的消息发送到单个Kafka主题。有没有办法定义一个能够使用两种类型消息的Spring Cloud Stream的功能消费者？
共有1个答案
使用事件路由功能，您可以拥有多个消费者，然后使用路由功能路由到正确的消费者。有关更高级的内容，请参阅此示例。然而，我意识到这不是您的用例，但想提一下以防万一。在消费者方面，如果使用域对象，则很难接受多种类型。例如，如果您传入的POJO是Foo（消费者
-
我需要使用gRPC从不同类型但语义相关的服务器获取一些数据。你可以把它看作是一个数据类型，可以有a、B和C。我在想，将这些数据传输到客户机的正确方法是什么。我个人可以想出三种不同的方法： 使用带有的单个消息： 在这个方法中，我只定义了一条消息，如下所示： 现在我只添加了一个rpc方法，它可以获取不同类型的数据。这种方法的问题是可扩展性。我将无法通过向此处所述的添加新的消息类型来更新我的消息（或者至
-
我正在编写一个使用Kafka流的应用程序。它从主题A读取，进行一些转换，然后写入主题B。在转换期间，值按键分组，因此输出键、值类型不同于输入值类型。Kafka流使用特定类型的Serdes（例如String serdes序列化和反序列化字符串）进行序列化和反序列化，因此在数据转换后它将无法工作。如何在Streams API中定义不同的序列化器和反序列化器？
-
假设我有以下消息： 现在，我想为不同类型的Msg重用相同的FSM actor，如下所示。在本例中，我们使用泛型类型Msg作为消息类型。当我实例化这个参与者时，我希望以某种方式指示我希望接收哪种类型的消息。 而不是像下面那样复制代码： 这有可能吗？注意：我不想在同一个参与者中有不同的案例陈述。他们应该是不同的演员，碰巧收到不同的Msg亚型。其余的逻辑在不同的实例中是相同的。
-
注：内容翻译自官网文档 Language Guide (proto3) 中的 Using Other Message Types 一节 可以使用其他消息类型作为字段类型. 例如, 假设你想在每个SearchResponse消息中包含Result消息 - 为了做到这点, 你可以在相同的.proto文件中定义Result消息类型然后具体指定SearchResponse中的一个字段为Result类型:
-
我已经在我的nuxtjs项目中使用了nuxt auth。在此处输入图像描述
-
我想基于泛型值返回不同的类型。例如： 但我有一个错误： 类型字符串[]不能分配给类型T扩展Base？String[]：字符串