我想建立一个单一的Spring Boot应用程序,同时做多种不同的任务。我在互联网上做了研究,但我找不到任何出路。我来详细说说。我希望每隔一段时间启动一次作业,例如一天一次。我可以用Spring石英来做。我也想在一个专用的互联网地址上听信息。消息将来自Apache Kafka平台。因此,我想将Kafka集成用于Spring框架。它实际上是否适用(始终监听消息并按时执行计划的作业)
从功能上来说,这种设计很好:一个Spring Boot应用程序可以在执行quartz作业的同时使用Kafka消息。
但是更高层次,你应该问为什么这两个功能属于一个app。石英工作和被消费的Kafka信息之间有什么内在联系吗?您是否只是将它们结合起来,仅仅是为了将自己限制在一个应用程序上,并节省计算/内存资源?
您还应该考虑对可伸缩性的影响。如果您需要提高使用Kafka消息的速率,该怎么办?如果你扩展你的应用程序以吸引更多的Kafka消费者,你就必须担心多个应用程序现在会让你的石英工作。
所以,是的,这是可以做到的,但是没有任何细节,听起来你应该把这个设计分成2个独立的应用程序:一个用于Quartz,一个用于Kafka消费。
我想使用JMS向Azure服务总线发送预定消息。我的代码基于。我已经为给定的问题找到了一个解决方案,但它使用,其中包含,它允许编辑消息注释并添加Azure服务总线正确识别和处理的一些属性。我的消息iml缺少那个方法。 我在node.js的官方文档和实现中发现,要使用Azure服务总线安排消息,您需要发送具有有效json的标头。其他标头/属性将标记为并被Azure服务总线忽略。 关于JMS的azur
我已经启动了我的zookeeper和Kafka服务器。我开始制作Kafka,它发送10条主题为“xxx”的消息。然后阻止了我的Kafka制作人。现在我开始使用Kafka,并订阅了主题“xxx”。我的消费者使用我的Kafka制作人发送的10条消息,这10条消息现在没有运行。我需要我的Kafka使用者只能使用来自运行Kafka服务器的消息。有没有办法做到这一点?以下是我的消费者财产。
我已经更新了我的Kafka从版本0.10.2.0到版本2.1.0,现在Kafka不能消费消息。我使用Spring引导,这是我的配置: 我已经更改了组id,以避免旧组id出现问题。我当前的spring版本是2.1。2.释放。在我的应用程序中,我可以看到我的客户是如何不断地重新连接的 你知道这个问题吗?
Kafka过去在我自己的电脑上工作得很好。我正在另一台电脑上工作,上面写着 为目录C:\tmp\kafka logs(kafka.server.LogDirFailureChannel)java中的\uu consumer\u offset-41创建日志时出错。木卫一。IOException:映射在sun失败。尼奥。总经理。Kafka地图(FileChannelImpl.java:940)。日志抽
在本公司的最后一个项目中:客户提出身份验证等请求,应用程序第一层得到客户请求并在Kafka上生成消息,核心服务消费该消息后向银行服务提出rest请求,得到响应后在Kafka上生成响应消息,应用程序第一层将消息传递给客户。是真的Kafka用例,还是去掉第一层和Kafka,在客户端和核心之间使用rest服务更好。谢谢
我刚开始学Kafka,Kafka-蟒蛇。在下面的代码中,我试图在消息到达时读取它们。但出于某种原因,消费者似乎要等到一定数量的消息积累后才能获取它们。 我最初以为是因为正在批量出版的制片人。当我运行“kafka-console-consumer--bootstrap-servers--topic”时,我可以看到发布后收到的每一条消息(就像在consumer控制台上看到的那样) 有人能指出用KafK