Spring-Kafka与Spring-Cloud-Stream（Kafka）的比较
在微服务架构中使用Kafka作为消息系统，使用spring-kafka与spring-cloud-stream + spring-cloud-starter-stream-kafka有什么好处？ Spring Cloud Stream框架支持更多的消息系统，因此具有更模块化的设计。但是它的功...
Spring Boot测试失败，显示“由于缺少ServletWebServerFactory bean而无法启动ServletWebServerApplicationContext”。
测试类：@RunWith(SpringRunner.class) @SpringBootTest(classes = { WebsocketSourceConfiguration.class, WebSocketSourceIntegrationTests.class }, w...
@EnableBinding已弃用，自3.1起采用函数式编程模型。
我看到Spring Cloud Stream中以下注解已经过时： @Input @Output @EnableBinding @StreamListener 请提供使用函数式方式的示例和文档链接。
发送消息到kafka主题时序列化错误
我需要测试一个包含头部信息的消息，所以我需要使用MessageBuilder，但是我无法序列化它。 我尝试在生产者属性中添加序列化设置，但没有起作用。 有人能帮助我吗？ 错误信息如下： org.apache.kafka.common.errors.SerializationExcept...
已请求默认绑定器，但 'org.springframework.cloud.stream.messaging.DirectWithAttributesChannel' 没有可用的绑定器。
我正在尝试使用Spring Cloud + Kafka Streams + Spring Boot 2创建最简单的“Hello World”应用。我意识到我缺少一些基础概念。基本上，我理解：1 - 我需要定义一个出站流（outbound stream），将消息写入Kafka主题，以及一个入站流...
Kafka INVALID_FETCH_SESSION_EPOCH
我们正在使用一个Kafka代理设置，配合使用Spring Cloud Stream Kafka运行的Kafka Streams应用程序。尽管它似乎可以正常运行，但我们在日志中确实会收到以下错误提示：2019-02-21 22:37:20,253 INFO kafka-coordinator-h...
无法检索所请求的元数据 /latest/meta-data/public-hostname
我正在使用spring-cloud-stream和AWS Kinesis绑定器部署Spring Boot应用程序。 如果beanstalk配置了公共IP，则该应用程序在部署到AWS Elastic Beanstalk上时可以正常工作。 当我们将beanstalk设置为私有IP时，应用程序在部署...
Spring AMQP相对于Spring Cloud Stream在微服务架构中有哪些优势？
我使用Spring Cloud方法构建了几个微服务，这些微服务应该相互交互。我打算使用RabbitMQ和Spring AMQP进行微服务之间的消息传递，但是在看了Spring Cloud Stream之后，我感到迷茫。在我看来，Spring Cloud Stream是许多非常有用的特性的抽象化...
墓碑消息未从KTable状态存储中删除记录？
我正在使用KStream创建KTable来处理数据。但是当我触发一条键为null且负载为null的删除消息时，它并没有从KTable中删除该消息。 示例 -public KStream<String, GenericRecord> processRecord(@Input(Cha...
AWS Kafka（MSK）- 如何生成Keystore和Truststore并在我的Spring Cloud Stream应用程序中使用？
是否有关于如何在我的Spring Cloud Stream应用程序中使用AWS MSK详细信息的信息？ 我认为我们需要生成密钥库和信任库，然后将其纳入我们的应用程序中？我阅读了AWS MSK的“客户端身份验证”页面，发现它非常令人困惑。 有人可以帮我解释一下这个过程吗？我只是想部署使用AW...