Spring云流Kafka流-如何在流中记录不一致的消息？
是否可以记录来自流函数的入站消息？有什么拦截器能让我这么做吗？
共有1个答案
使用kstream.peek(streamlogger::in)方法记录传入字符串：）
-
我正在尝试用《Spring的云流》和《Kafka》。下面是示例代码。但它似乎没有任何作用。它总是创建一个名为“输出”的主题。但这些价值观尚未公布。 应用亚马尔 我的目标就是创造价值。 依赖性-2.2.6。释放
-
如何使用新的Spring Cloud Stream Kafka功能模型发送消息？ 不推荐的方式是这样的。 但是我如何以函数式风格发送消息呢？ 应用yml公司 我会自动连接MessageChannel，但对于process、process-out-0、output或类似的东西，没有MessageChannel Bean。或者我可以用供应商Bean发送消息吗？谁能给我举个例子吗？谢谢！
-
一段时间以来，我一直试图让Spring Cloud Stream与Kafka Streams一起使用，我的项目使用嵌入式kafka进行Kafka DSL测试，我使用这个存储库作为我的测试实现的基础（它本身就是这个问题的测试用例）。 我在这里制作了一个存储库来演示这一点。 基本上，当使用“Processor.class”的“DemoApplicationTest.ExampleAppWorking.
-
我用的是Apache Kafka 2.7.0和Spring Cloud Stream Kafka Streams。 在我的Spring Cloud Stream (Kafka Streams)应用程序中，我已经将我的application.yml配置为当输入主题中的消息出现反序列化错误时使用sendToDlq机制: 我启动了我的应用程序，但我看不到这个主题存在。文档指出，如果 DLQ 主题不存在，
-
如何使用项目Reactor背压功能与Kafka粘合剂在斯佩林云流？ 如果我使用这种方式，比发布者发送延迟1秒的消息，但消费者消费消息没有任何延迟。 有可能在春雨云流中使用cunsumer上的BackPereSure吗？