个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
28
4
我想将 Kafka 与 Spring Boot 和 Avro 模式一起使用。
但我被困在“这三个听众之间有什么区别？”。
创建监听器有 3 种可能性: 使用 - @KafkaListener 注释方法, @StreamListener或 @ServiceActivator .似乎所有人都在监听传入事件，但我看不到/找到这些解决方案之间的区别。
最佳答案
所以，我将从 @KafkaListener 开始.那个很简单，因为它来自“spring-kafka”项目，可以在 Spring Cloud Stream 之外使用。@ServiceActivator来自“spring-integraton”项目，类似于 @KafkaListener可以在 Spring Cloud Stream 之外使用。
两者也可以在 Spring Cloud Stream 应用程序内部使用 - 主要是为了方便。@StreamListener是 Spring Cloud Stream 中唯一原生的。
对于简单的情况，您可以自行选择。对于更复杂的情况，请参阅特定注释的额外功能。例如，您可以在使用 @StreamListener 时定义条件.
关于spring-cloud-stream - @KafkaListener、@StreamListener 和 @ServiceActivator 之间的区别？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47535196/
28
4
0
我正在使用 Spring Cloud Stream 3.1.2为 KafkaStreams .编程模型是: 函数式编程 命令式编程 后一个使用注解作为 Spring 提供以供使用的所有其他注解。但是，
我正在为多个 Spring Boot 应用程序实现一个通用库，它将为 Kafka 提供一个简单的接口(interface)。我选择了 Spring Cloud Stream 来集成 Kafka。该库必
只是一个快速的。 是否可以使用 Spring Cloud Stream 进行响应式(Reactive) @StreamListener Input？我的意思是这样的: @StreamListener
我目前非常简单的代码应该使用 twitter 流 API 将特定关键字下的所有推文简单地打印到控制台中。但是我不知道如何获取推文的全文而不是截断版本。该程序还在其他地方利用 new_tweet
假设，我能够通过 Kafka 或 RabbitMQ 发送消息并使用 @StreamListener 使用它们。 Binders 是为 content-type = 'application/json'
我有多个使用不同主题的 StreamListener 注释方法。但是其中一些主题需要从“最早”的偏移量读取，以填充内存中的映射(类似于状态机)，然后从其他主题中使用，这些主题中可能包含应针对“最新”执
假设，我能够通过 Kafka 或 RabbitMQ 发送消息并使用 @StreamListener 使用它们。 Binders 是为 content-type = 'application/json'
我想创建一个 KTable(将来会是一个 GlobalKTable)来跟踪使用 Spring Cloud Streams 通过我的 Kafka 代理的条目。 我现在拥有的代码从监听器的角度来看应该可以
我可以使用代码发送和接收消息: @EnableBinding(Processor.class) public class KafkaStreamsConfiguration { @StreamLi
我是 python 的新手，我正在尝试开发一个应用程序，该应用程序使用 Tweepy 和 Streaming API 从 Twitter 检索数据并将数据转换为 CSV 文件。问题是这段代码不会创建输
我有一个服务调用了十几个其他服务。这使用 Controller 类中的 @StreamListener 来读取 Kafka 主题。出于可追溯性的目的，来自 Kafka 消息的相同 header (原始
我正在尝试从特定 hastags 中恢复推文。我正在使用 Python 2.7.6 和 Tweepy 来收听 hastag。关注本文:Introduction to tweepy, Twitter f
我正在尝试使用 twitter4j 获取推文。我尝试了示例代码，我明白为什么它不起作用 - 我无法转换 StatusListener。但我也无法解决我的问题。 有人知道如何解决这个问题吗？ impor
伙计们，我想在我的文件中保存 Twitter 用户信息，如姓名、状态、推文(首选 json、txt、csv 或任何其他 json 或文本)。我尝试了这段代码和其他一些类似的代码，但都没有用。伙计们看看
我想将 Kafka 与 Spring Boot 和 Avro 模式一起使用。 但我被困在“这三个听众之间有什么区别？”。 创建监听器有 3 种可能性: 使用 - @KafkaListener 注释
我使用 Spring cloud strema Kstream。 我测试一个主题和一个 @StreamListner .没关系。 我修改了两个 KStream 输入的代码。 (两个 @StreamLi
我们努力寻找以下场景的解决方案: 情况 通过 Spring Cloud Streamlistener 接收消息 通过 Feign-Client 调用 REST 服务 我们配置了几个Feign-Requ
我有一个生产者(Source)，它将消息写入 Kafka 输出 channel ，该生产者发送不同类型的对象。在消费者端(Sink)，我希望在同一输入 channel 上有多个@Streamliste
我有一个应用程序，它从 Kafka 获取消息并调用目标系统来更新旧版 Oracle 数据库。 我想启用一个场景，如果目标系统关闭，则将消息留在 Kafka 总线上，并且在给定的时间内不处理它们。我正在
我正在使用 Spring Boot 2.4.2 版并使用 @InboundChannelAdapter 进行 Spring Cloud Stream 和 Spring Integration . im
我是一名优秀的程序员,十分优秀！