我正在尝试构建一个Sping Boot WebFlux应用程序，它使用一个Kafka主题中的事件，并对其进行一些处理（将涉及React性数据库查找操作），然后将它们发送到另一个Kafka主题。目前，该应用程序使用webflux和spring云数据流来处理Kafka。
有人能建议使用Spring Cloud Stream Kafka Stream API吗？或者我应该使用其他东西来实现端到端的React行为。
尝试了用Sping Boot WebFlux，Spring的云数据流Kafka流。
此处为处理器示例
1条答案
按热度按时间6bc51xsx1#
看起来您并没有使用Spring Cloud Stream Kafka Streams绑定器，但是您提到了
Spring Cloud Stream Kafka Stream API。我假设您使用的是基于消息通道的Spring Cloud Stream中的常规Kafka绑定器，因为您提供的代码中没有指向任何Kafka Streams API的内容。假设是这样，实现完全端到端React行为的最佳方法是使用新型React性Kafka粘合剂（尚未发布，但属于4.0.0版本的一部分，目前正处于RC阶段）。更多关于这种React性Kafka粘合剂的详细信息可在这里获得。此绑定器实现基于Project Reactor的reactor Kafka项目。常规的基于消息通道的Kafka绑定器不基于React式模型，并且可能在使用/生成时阻塞。因此，如果您正在寻找端到端React式范例，使用活性Kafka粘合剂。