在使用Spring Cloud Function的Spring Boot Kafka流处理应用中，只有在响应当前消息之后，我才能关闭应用程序(以阻止其接收任何进一步的消息)？场景是这样的:我们有一个应用程序，它处理一个包含对某个文件的引用的消息。我们通过使用一些第三方库查询给定文件的内容，并使用从文件中提取的一些数据进行响应来处理此问题。我们需要为此消息<
浏览 39提问于2021-01-26得票数 0
我想用kafka流实现请求-响应模式，我使用了spring boot kafka，它添加了一些数据作为头部，命名为关联id，但是当请求消息被kafka流API处理时，头部数据会丢失，不能发送到响应主题！我如何解决它，或使用其他方法？？
浏览 0提问于2020-04-19得票数 0
1回答
我正在开发一个使用Kafka流的spring boot应用程序，在我的应用程序中，我希望管理Kafka偏移量，并在仅在成功处理消息的情况下提交偏移量。这一点很重要，确保即使Kafka重启或zookeeper关闭，我也不会丢失消息。我目前的情况是，当我的Kafka断断续续时，我的消费者从头开始并使用所有之前的消息。另外，我需要知道使用autoCommitOffset自动管理K
浏览 3提问于2020-01-16得票数 0
我的要求是，当应用程序无法处理从通过spring boot java应用程序使用的kafka主题的当前偏移量读取的消息时，重置kafka主题的偏移量。在手动重置偏移量或发送否定确认之后，需要通过spring boot java应用程序的kafka消费者再次从不合适的偏移量值轮询消息。它能实现吗？
浏览 3提问于2019-01-09得票数 1
在我的应用程序中，我使用Spring Boot kafkaTemplate来消费消息。我是新手使用Spring Boot的kafka。我添加了一个消费者，如下所示： @KafkaListener(topics = "#{'${app.kafka.consumer.topic}'.split(',')}") log.info("Me
浏览 136提问于2021-09-14得票数 0
我正在尝试处理失败，并将消息写入failure-Q，以防消息在db期间由于db停机或任何其他问题而失败。# KAFKAkafka.topic.consumer.boot: tink_boot.j
kafk
浏览 6提问于2020-03-27得票数 0
我们正在使用Kafka流媒体库来构建关于Kafka主题的传入消息的实时通知类系统，因此当流媒体应用程序运行时，它会实时处理主题中的所有传入消息，并在遇到某种预定义的传入消息时发送通知。如果流应用关闭并重新启动，我们只需要处理流应用初始化后最近到达的消息。这是为了避免处理在流媒体应用程序未运行或停机时未处理的旧记录。默认情况下，流式应用程序开始<e
浏览 2提问于2018-05-10得票数 2
我正在使用camel-spring-boot-starter中的camel- kafka ，在spring引导项目中将一条消息从一个卡夫卡主题路由到另一个。在某些主题上，我当前的应用程序，它只使用、camel-kafka、和(没有弹簧云流)。
浏览 2提问于2018-06-20得票数 0
我正在尝试在Spring Cloud数据流中配置DLQ。=test-tran,app.log.spring.cloud.stream.bindings.input.destination=test-tran,app.custom-transform.spring.cloud.stream.kafka.bindings.test-tran.consumer.enableDlq);这意味着如果消息包含错误，那么RunTimeExcep
浏览 0提问于2016-09-16得票数 0
有谁有使用kafka stream和spring boot将消息作为流读取的hello world示例。 我的kafka集群是受SASL_安全保护的。那么我如何将我的spring boot kafka流应用程序与。在application.properties文件中写什么。 我不想用春天的云溪。spring.kafka.producer.value-seriali
浏览 21提问于2020-07-10得票数 0
我正在开发一个Spring Boot应用程序，它使用以Kafka主题为源的Spring集成流。我们的集成流开始使用一个包含带有springframework.cloud.stream.annotation.Input和输出注释的SubscribableChannels的接口。这些配置为通过云配置和spring.cloud.stream.kafka.bindings从Kafka读取。
当应用程序第一次启动时，它会立即开始读取Ka
浏览 0提问于2018-04-24得票数 1
我使用Spring Boot 2.0.7和Spring-Kafka来创建请求/应答模式。基本上，前端UI向API发出请求，API将消息放到请求Kafka队列中，消息由后端进程处理，完成后将消息放到应答队列中。
我想提供的前端用户界面的api，等待，直到响应准备就绪。此时的UI将仅显示一条正在处理的消息。如果响应不可用(例如，2分钟后)，API应该只返回<
浏览 1提问于2018-12-08得票数 0
我在这个网站上发布了基于的Spring云数据流。
export STREAM_APPS_URI=https://dataflow.spring.io/Einstein-BUILD-SNAPSHOT-stream-applications-kafka-maven我继续注册这3个应用程序，然后用它们创建一个流，然后运行它。问题1:流的状态总是“部署”。不应该部署吗？我使用
浏览 2提问于2019-09-11得票数 4
我们正在开发SCDF上的项目，kafka版本2.4.1用于数据流，2.3.1用于skipper。我有一个云流应用程序，它在我的IDE中进行单元测试时工作得很好。但当我注册为处理器时，我在我的Stream中看不到此特定应用程序的日志中的任何活动。 当前使用Boot2.2.5和Hoxton.SR3。但当我使用spring boot版本2.1.4时，这款应用运行得很好。我使用spring boot 2.1.4的原因是这个U
浏览 13提问于2020-03-25得票数 0
这是另一种"KStream"，一种“耐久的反应流”吗？它的使用是否保证不滞后，或至少最小，因为背压？
浏览 4提问于2022-09-14得票数 0
回答已采纳
我使用的是Spring Boot2.1.1.RELEASE和Spring Cloud Greenwich.RC2，spring-cloud-stream-binder-kafka的托管版本是2.1.0RC4Kafka版本为1.1.0。我设置了以下属性，因为如果出现错误，消息将不会被使用。Kafka使用者为它处理的每个消息调用一个web服务，如果web服务不可用，那么我预计使用者将尝试处理该消
浏览 29提问于2019-03-18得票数 2
1回答
我有一个spring boot应用程序，当我停止spring boot应用程序时，akka参与者即使有要处理的消息也会被终止。我想要改变行为，并希望即使在spring boot应用程序关闭后，如果akka演员有它应该处理的消息，之后它应该被终止，我尝试了多种方法，但没有任何运气，我尝试优雅地关闭spring boot。
浏览 18提问于2021-11-16得票数 0
嗨，我是Spring Boot @kafkaListener的新手。服务A不断在kafka topic上发布消息。我的服务使用来自那个topic的消息。两个服务(服务A和我的服务)中的topic分区是相同的，但是与发布消息相比，使用消息的比率很低。我可以在lag中看到kafka。
我怎样才能填补这个空白呢？或者如何提高信息的消耗率？可以有单独的线程来处理消息。我可以在队列中使用一条消息</e
浏览 2提问于2021-10-19得票数 0
我正在使用@KafkaListener(topics = "${topic}")来消费来自spring-boot应用程序中某个主题的消息，并且我需要定期运行该应用程序。spring-kafka版本是2.2.4.RELEASE。
要实现这一点，一种方法是使用fetch.max.wait.ms每6小时进行一次批处理，但对于这种配置来说，6小时似乎太多了。因此，我正在寻找一种方法，在处理后关闭应用程序，并每6小时重新启动
浏览 16提问于2020-05-06得票数 0
回答已采纳
我正在写一个使用Kafka Streams，Spring-Kafka和Spring Boot的流应用程序。在使用Spring-Kafka时，我找不到任何信息来正确测试Kafka Streams DSL所做的流处理。文档提到了EmbeddedKafkaBroker，但似乎没有关于如何处理测试的信息，例如状态存储。 只是提供一些简单的例子来说明我想要测试的内容。
浏览 25提问于2019-08-31得票数 3
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
