如何在Kafka Streams中为不同的处理器使用不同的服务器？
我有一个拓扑，其中我有2个不同的源主题（2个子拓扑）。其中一个是Avro格式，另一个是JSON格式。有没有办法为不同的处理器使用不同的SERDE？我已经看到商店里有消费。使用（）但我看不到处理器有这样的功能。
除了编写自己的序列化程序或反序列化程序来区分主题和相应的序列化/反序列化之外，是否有使用不同Serde的配置？
共有1个答案
Topology类包含带有序列化器和反序列化器的addSource方法
Topology addSource(String sourceName, Deserializer keyDeserializer, Deserializer valueDeserializer, String... topics)
-
对于登录页面自动化，用户需要输入用户id、安全答案和密码。不同的环境有不同的用户。例如，qa和dev环境的用户具有不同的用户id、安全答案和密码。那么在自动化测试中如何妥善处理用户信息呢？我们可以将所有的属性存储在属性文件中，还有其他更好的解决方案吗？
-
由于在所述实体不可用的情况下返回，因此需要进行如上所示的条件测试，以避免可能的，否则很可能发生。在任何地方重复这个琐碎的条件测试都是非常不可接受和不鼓励的，这使得业务逻辑应该尽可能简单，几乎不可读。 为了防止这种条件检查到处重复，我在一个单独的EJB中有一个通用方法， 从另一个EJB内部调用此方法，如下所示， 在这里，尽管所有事情都发生在同一个事务中，返回，即返回的实体由两个EJB中的管理。 虽然
-
我已经开始为CDC测试实施PACT。我如何处理我们在不同环境的路径中传递不同参数的场景？ 例如，我的测试调用一个函数，该函数通过命中endpoint并传递一些参数来请求服务中的一些数据。非常标准。 E、 G： 对于不同的环境（QA、UAT等），必须传递特定于该环境的唯一数据，以获得有效的200响应。因此，在我的示例中，每个env的carId和userId需要不同。当我最初设置测试时，我使用了我们的
-
我正在使用java-8进行多个Spring boot项目，但现在其中一个需要转移到java-11。所以我需要在笔记本电脑上安装两个版本。那么如何在同一台机器上为不同的项目处理不同的JAVA版本呢？
-
因此，我的discord机器人有一个数组，字符串形式的对象可以通过我发出的discord命令推送到该数组中，然后将该数组导出到另一个事件文件中，该文件将检查数组中的这些单词是否存在于消息中。 但是我遇到了一个问题，如果我添加一个单词，让我们从服务器1说“a”，然后从服务器2说“b”，然后对机器人所在的每一台服务器都检查单词a和b，这绝对不是我所说的通缉。 我尝试使用maps（），但由于某些原因，我
-
问题内容： 我的网站托管在不同位置的多台服务器上 到处数据格式的文化都不尽相同- 我们在每个地方都使用格式，但如果某些服务器设置了文化，则我们的网站将生成Datetime异常。 问题答案： 您应该在将字符串转换为日期时指定要使用的区域性。 您应该使用的区域性取决于日期格式的区域性。例如，如果您要解析的所有日期都被格式化为 Slovak ： 然后，您需要像在 斯洛伐克（Slovakia） （）文化中