如何暂停Spring云数据流源类向kafka发送数据？
要暂停Spring云数据流源类向Kafka发送数据，可以通过以下步骤实现：
- 在Spring Cloud Data Flow中，数据流源类是通过绑定器（Binder）与消息中间件（如Kafka）进行通信的。因此，要暂停数据流源类向Kafka发送数据，可以通过配置Binder的属性来实现。
- 找到数据流源类的配置文件（如application.properties或application.yml），添加以下配置：
- 找到数据流源类的配置文件（如application.properties或application.yml），添加以下配置：
- 其中，
<bindingName>是数据流源类与Kafka之间的绑定名称。 - 重新启动数据流源类应用程序，使配置生效。
通过以上配置，数据流源类将不再向Kafka发送数据，而是将数据发送到绑定器的输出通道。这样可以实现对数据流源类的暂停操作。
注意：以上答案是基于Spring Cloud Data Flow框架的，如果使用其他云计算平台或自定义的解决方案，可能会有不同的配置方式。
相关·内容
1回答
我正在从Spring迁移到Spring数据流。当我寻找模块列表时，我意识到有些源没有在中列出--其中之一就是KAFKA源代码。
我的问题是为什么在春云数据流中从标准源列表中删除KAFKA源？
浏览 4提问于2016-07-24得票数 4
回答已采纳
我正在开发一个Spring Boot应用程序，它使用以Kafka主题为源的Spring集成流。我们的集成流开始使用一个包含带有springframework.cloud.stream.annotation.Input和输出注释的SubscribableChannels的接口。这些配置为通过云配置和spring.cloud.stream.kafka.bindings从Kafka读取。
当应用程序第一次启动时，它会立即开始读取Kafka主题。这是一个问题，因为应用程序需要初始化一些本地的、不可持久的数据库，然后才能开始正确处理传入的Kafka消息。
我们目前正在使用@PostConstruct在K
浏览 0提问于2018-04-24得票数 1
2回答
我正在使用任务云模块的spring数据流，但是我在午餐上遇到了一些麻烦，这是一个容器中的简单例子。编写代码时，我已经部署了它，但是当我试图执行它时，我会抛出一个
org.springframework.util.Assert.notNull(Assert.java:134)：无效的TaskExecution，在org.springframework.cloud.task.listener.TaskLifecycleListener.doTaskStart(TaskLifecycleListener.java:200)的java.lang.IllegalArgumentException上找不
浏览 3提问于2017-08-29得票数 2
我想了解一下spring云数据流的体系结构。特别是使用它来编排纯粹的批处理管道。我已经在k8s中部署了所有组件，并且注意到我可以在没有中间件(Kafka / RabbitMQ)的情况下部署skipper组件，并通过服务器组件成功地运行批处理作业。
根据我可以看到的文档，skipper用于编排流作业。当纯粹用于批处理作业或任务时，skipper (以及随后的Kafka/RabbitMQ中间件)是否是春季云数据流的必要部分？
浏览 0提问于2020-04-23得票数 0
回答已采纳
2回答
我正在将我的一些应用程序转移到微服务领域。一个示例服务是RSS爬虫，它使用向Kafka发送项目。我还看到了Spring数据流，它使用Spring集成和Spring批处理。
如果我使用Spring数据流，我是在每个微服务中使用这个，还是将它用作微服务之间的编排？
我正在尝试理解引入Spring数据流的好处，而不是使用Spring来保持微服务尽可能轻。
如有任何建议，将不胜感激。
浏览 0提问于2018-04-19得票数 11
回答已采纳
1回答
使用spring云数据流运行我的spring云流应用程序的最简单方法是什么？我的想法是创建自定义的源代码，使用kafka绑定器和接收器作为预构建的启动程序，文件。我正在创建applciation，它非常基本，类似于。我尝试创建可执行的jar，并使用dataflow shell将其注册为源代码，但这根本不起作用。我已经在跟踪这个了。
浏览 2提问于2016-07-27得票数 0
回答已采纳
我使用过spring cloud data flow、rabbitmq和kafka，但我想知道是否可以使用google pub/sub安装scdf。
我不想创建一个流(新的应用程序，spring云流)，它的源或宿都是gcp，我想让google pub/sub over spring cloud数据流服务器作为一个中间消息传递代理。
有什么建议吗？
浏览 1提问于2019-12-30得票数 1
1回答
我正致力于为银行创建一个大容量的JSON数据处理应用程序，使用Spring、Kafka和QuickFIX/J。这是我第一次使用Kafka和QuickFIX/J这样的技术，无法决定是使用普通的Kafka spring还是Kafka流还是spring云流。以下是要求：
从多个进程读取数据，并将数据发送给QuickFIX/J启动器，后者进一步将其发送到外部修复引擎-- QuickFIX/J受体从外部修复引擎接收数据，并将其再次写入多个卡夫卡主题，但这次不同的是。
我读过一些教程/文章，这些文章说Kafka流或spring云流是好的，如果您有消费者/生产者，执行高容量的数据流，并希望实现一次处理。但是
浏览 7提问于2020-06-01得票数 0
大家好，还有一支特别的春天队！
如何用函数Bean编程模型风格的spring云流来流水线弹簧云函数？
例如，我有两个依赖项的pom.xml：
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-reactive</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud&l
浏览 0提问于2019-06-09得票数 1
回答已采纳
1回答
我们正在设计将我们的单块Java应用程序移植到微服务的过程中，以满足各种客户端的需求，如可扩展性、高可用性等。应用程序的核心功能是数据处理，即从源中检索数据，进行0或多个转换，最后将结果推送到目的地。因此，我们看到运行在Kubernetes和Kafka上的Spring数据流为我们做了繁重的工作，使用了一些定制的流应用程序来处理我们的业务逻辑。
不过，有一件事我们还没有弄清楚，那就是它如何处理通过HTTP源发送的请求的同步响应--特别是在响应之前需要进行一些处理。例如，假设接收到一个请求，其中包含JSON数据包中的两个不同数量。然后，我们将其传递给一个自定义的“加法”转换器，该转换器输出这些金额
浏览 5提问于2021-12-10得票数 0
回答已采纳
我正在尝试构建一个Spring应用程序，它使用来自一个Kafka主题的事件，对其进行一些处理(可能涉及对反应性db查找的操作)，并将它们发送到另一个kafka主题。目前，该应用程序为kafka使用了webflux和spring云数据流。
请有人建议使用好吗，还是应该使用其他方法来实现端到端的反应行为。
尝试用Spring引导WebFlux，春季云数据流卡夫卡流。
这里的处理器示例
浏览 7提问于2022-12-02得票数 0
我们正在开发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的原因是这个URL上的示例应用程序使用2.1.4 因此，如果有文档可以让您知道SCDF发行版使用哪些spring boot版本，这会很有帮助。
浏览 13提问于2020-03-25得票数 0
1回答
我想在SpringCloud数据流中使用Kafka /Sink，但我在春季云流应用程序启动器中找不到这些应用程序启动器。它们在Spring中提供。有人知道他们为什么失踪吗？
谢谢
浏览 2提问于2017-03-20得票数 0
回答已采纳
我们有一个要求，我们使用Kafka Streams读取Kafka主题，然后通过一个会话池通过网络发送数据。然而，有时，网络调用有点慢，我们需要频繁地暂停流，以确保我们不会使网络过载。目前，我们将数据捕获到流中，并将其加载到executor服务，然后通过会话池通过网络发送。
如果executor服务中的数据太高，我们需要暂停流一段时间，然后在executor服务上的积压清除后恢复它。为了实现这种暂停机制，我们目前正在关闭流，并在积压清理完毕后重新开始。
有什么办法可以暂停kafka流吗？
浏览 2提问于2020-03-02得票数 1
2回答
使用Kafka作为微服务体系结构中的消息传递系统，使用spring相对于spring云流+spring-云-初学者流-kafka有什么好处？
spring云流框架支持更多的消息传递系统，因此具有更模块化的设计。但是功能呢？泉-卡夫卡的功能和弹簧云流+弹簧云-启动-流-卡夫卡的功能之间有差距吗？哪个API设计得更好？
期待阅读你的观点
浏览 5提问于2017-11-15得票数 56
1回答
我正在尝试将春初卡夫卡应用与阿里巴巴云上的卡夫卡联系起来。
云在上。
但是，我不能从启动连接，也许是因为我需要提供的安全证书？
我已经尝试将引导属性设置为：
spring.kafka.properties.security.protocol=SSL
获取错误:在身份验证期间终止到节点-1 (/xx.xx:9092)的连接。这可能是由于以下任何原因造成的：(1)身份验证失败是由于代理的凭据无效，代理的年龄超过1.0.0；(2)防火墙阻塞Kafka TLS通信量(例如，它可能只允许HTTPS通信)；(3)瞬态网络问题。
spring.kafka.properties.security.protoc
浏览 2提问于2020-03-02得票数 1
我已经开发了一个Flink程序，可以读取Twitter上的推文，并将它们推送到Kafka上。然后，它从Kafka获取tweet并对其进行处理。
"Tweets“转换从tweet的文本中提取标签和用户，并在默认输出中发出它们，并在副输出中发出它们的每一对。
附加的图像是从Flink Web UI中拾取的。我不明白为什么Kafka源和Tweets处理操作符合并到一个任务中，主要是我希望Tweets接收器接收所有来自Kafka源的原始Tweet，而不是tweets处理操作符的输出。
程序是正确的吗？
这是代码的相关部分：
FlinkKafkaConsumer010<Strin
浏览 1提问于2018-06-30得票数 1
1回答
我试图将我的源的最后一次阅读记录存储在kafka的一个单独的主题中，作为一个流源。如何使用spring云数据流应用程序实现这一目标。任何建议都会有很大帮助。
浏览 3提问于2017-04-04得票数 0
回答已采纳
我很难理解GCP、数据流/Apache和之间的区别。我想要做的是转向一种更适合于流数据处理的云本地解决方案，这样我们的开发人员就可以更多地关注核心逻辑的开发，而不是管理基础设施。
我们有一个现有的流解决方案，它由spring云数据流‘模块’组成，我们可以独立地迭代和部署，就像微服务一样，它工作得很好，但是我们希望迁移到GCP中的一个现有平台，该平台由我们的业务提供，需要我们使用GCP Dataflow。在高层次上，解决办法很简单：
流1:
Kafka Source (S0) -> Module A1 (Ingest) -> Module B1 (Map) -> Module
浏览 2提问于2019-11-26得票数 1
回答已采纳
Spring云数据流文档提到
在外部执行任务(即命令行)并希望Spring数据流在其UI中显示TaskExecutions时，请确保公共数据源设置在两者之间共享。默认情况下，将使用本地H2实例，并且执行不会被记录到Spring数据流使用的数据库中。
我对Spring云数据流和spring云任务很陌生。有人能帮我建立一个共同的数据源吗。为了我的开发目的，我使用了嵌入式H2数据库。我可以使用嵌入的一个查看Spring /仪表板中的任务执行细节吗？
浏览 1提问于2017-09-29得票数 0
我们计划使用Azure EventHub作为消息绑定器，在Azure云上使用Spring数据流。在Azure EventHub上，有一些严格的限制：
100个命名空间
每个名称空间有10个主题。
事件中心流绑定器似乎只能配置一个名称空间，那么我们如何管理多个名称空间呢？
也许我们应该使用，拥有多个Spring事件集线器流绑定器的实例？
有人有什么想法吗？还是我们找不到的文件？
问候
雷米
浏览 0提问于2020-06-18得票数 1
我们有一个现有的主题，其中数据由JDBC源连接器使用模式增量+时间戳发布(源连接器使用increment+timestamp () )
我们有现有的消费者群体，他们使用来自一些现有主题的数据。现在，我们正在引入一个新的使用者组(称为k组)，它应该使用来自相同现有主题的数据，并且应该写入数据库。作为第一步，在开始使用现有主题中的消息之前，我们有一个初始数据迁移工作流，以获取源数据库的转储并将转储复制到目标数据库。
现在，当消费者群体开始时，我想知道它应该从什么开始？
一种选择是使用latest。但问题是，当为这个新的使用者组执行初始数据迁移时，现有的源连接器将向现有主题发布数据。在我们的例子中，
浏览 0提问于2020-10-07得票数 0
1回答
我对春天的云流很陌生。
假设我使用@StreamListener(“输入通道”)收听kafka的一些主题的Spring云流应用程序。
我想做一些计算并将结果发送到另一个主题，但是在处理过程中，我还需要调用Hibernate (通过spring )将一些数据持久化到我的mySQL数据库中。
在流处理过程中调用Hibernate有效吗？还有其他模式可以做吗？
浏览 9提问于2021-12-15得票数 1
回答已采纳
我在春季云数据流中工作，在那里我有一个场景，比如从数据库中读取数据，并使用@In量InboundChannelAdapter将数据发送到kafka主题
下面是我遵循的策略。
如果列表为空，则使用->Created公共列表来存储对象
->if列表中有我不会投票的数据
->i将使用索引一个接一个地将值发送给卡夫卡，然后我将删除索引。
如果我保留@Bean，它只是将列表中的第一个对象插入到kafka主题中。
{"id":101443442，“名称”：“Mobile1”，“价格”：8000}
如果我删除@Bean，那么它将将所有空数据插入kafka中。
{}
浏览 4提问于2020-12-11得票数 0
到目前为止，我一直在研究spring云模式注册表和confluent模式注册表。我可以看到一些区别，比如spring云模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而confluent模式注册表保存在kafka topic中。 对于spring云模式注册表，这种方法有没有性能影响？据我所知，即使数据被保存在主题上，如果是合流的情况下，查询仍然会有延迟。但是会有很大的影响吗？ 我还可以看到，spring云模式注册中心提供了对confluent模式注册中心的支持，这是否意味着confluent模式注册中心更好？ 这些模式注册中心的工作方式有什么根本区别吗？ 如果confluent模
浏览 26提问于2021-06-29得票数 0
1回答
我正在使用IBM构建一个应用程序。所建议的构建它的架构是使用spring云流。我在许多文章中读到，您可以将spring云消息传递系统移植到其他系统。这意味着，我以后也可以将IBM更改为kafka，但可以在类路径上提供绑定器实现。那是什么意思？
我使用rabbitmq构建了一个Spring应用程序，我在应用程序中使用的特性是belo，
请求答复
Dlq
生产者和监听器配置都是向上和向下的，这意味着我可以创建一个队列，它的交换和绑定路由密钥使用代码。
如果我使用spring云流，我想知道上面的特性是否可用，是否需要将实现代码更改为将ibm移植到kafka？
浏览 1提问于2018-11-25得票数 0
1回答
我试图找到Spring数据流和Azure服务总线设置的一些例子。。
我已经找到了，但它仍然在RC中，我没有看到任何示例(涵盖Spring数据流)。
你能帮我理解一下，如果我可以一起使用Spring数据流和Azure服务总线吗？
我能够使用Kafka和RabbitMQ运行示例，但我找不到任何可以用作Spring数据流集成解决方案的Azure服务总线
浏览 0提问于2019-07-05得票数 1
回答已采纳
我正在尝试将春云流与春云功能webflux集成在一起。
由于它们在将来的版本中不推荐spring云反应性流，所以我尝试使用spring云函数。
Spring云web函数可以公开其函数的端点，路径类似于doc。
从云流中，我可以看到源需要定义为供应商
但是我的用例是从反应性http端点获取POST数据，并将其摄取到kafka中，有没有办法从spring云功能web和spring云流中实现呢？
从文档中获取包含弹簧云流的spring云函数。
@SpringBootApplication
@EnableBinding(Source.class)
public static class Source
浏览 2提问于2019-03-27得票数 2
回答已采纳
1回答
泉云流卡夫卡误码信道
、、、
我正在尝试设置一个绑定，以便将Kafka消息从Spring转发到自定义通道(用于集中化错误处理)。
错误消息被发送到配置的通道，但它们是以GenericMessage的形式到达的，byte[]有效负载由异常详细信息和失败消息组成。
我的配置：
spring:
cloud:
stream:
kafka:
bindings:
accountOut.producer:
sync: true
binder:
autoCreateTopics: false
head
浏览 0提问于2018-03-09得票数 0
回答已采纳
我一直在玩spring云流(1.0.BUILD-使用kafka绑定程序的快照)，并注意到在离线的消费者中，发送的任何消息都会丢失。当我启动消费者时，它不会处理发送给kafka的积压请求。这是故意的吗？
浏览 0提问于2016-03-06得票数 4
回答已采纳
我们的应用程序是使用Spring + Gradle构建的。我们对实现春季批处理作业提出了新的要求，它将使用autosys(作业调度工具)触发，它有3个步骤执行3种不同的操作(文件准备、ftp和审计操作)。我已经附加了@EnableBatchProcessing配置文件供您参考。以下是与Spring数据流相关的问题。
Spring云数据流项目可以使用Gradle构建吗？我看到了使用Maven和官方Spring页面构建的所有示例项目，Maven是Spring数据流必须的。Gradle是我们公司唯一获得批准的建设项目。
我们正在寻找Spring批管理UI类特性或在Spring数据流中的操作。
浏览 0提问于2019-05-31得票数 1
我可以使用spring-cloud-dataflow(kubernetes)来执行递归任务吗？我需要根据当前结果创建流的新实例(递归)。我需要任务的分布式处理。
1)是否需要使用message-source？据我所知，数据流使用自己的消息代理(兔，kafka)。我是否需要安装另一个代理，或者我可以在数据流代理中创建队列？
2)我可以在没有队列的情况下完成吗？
3)流与任务？
thx
浏览 2提问于2016-11-28得票数 0
1回答
无法暂停Spring容器
、、、
我想暂停卡夫卡的听众。
我调用来暂停容器
我发送关于这个话题的数据。
消费者开始消费信息。
我预计消费者会被暂停，但信息仍在阅读从卡夫卡的主题。我怎样才能暂停消费者？我使用的是2.5.0 (Spring父母)
@KafkaListener(id="foo" ,topics = "mytopic-3", concurrency = "3", groupId = "mytopic-1-groupid")
@Autowired
private KafkaListenerEndpo
浏览 1提问于2021-07-14得票数 2
回答已采纳
我在这个网站上发布了基于的Spring云数据流。
我创建了3个应用程序，源代码，处理器和水槽。
我在Spring数据流云仪表板上注册了它们。
然后，我创建了一个流，其中源连接到处理器，连接到接收器。
当我部署应用程序并打开{流名}时，
我得到以下错误，
{
logs: {
testdir-stream.sender1-v3: "Error: Unable to access jarfile /testdir/data-sender-0.0.1-SNAPSHOT.jar ",
testdir-stream.sink1-v3: "Error: Unable to acce
浏览 0提问于2019-09-09得票数 0
回答已采纳
在我的组织中有一个群集(2节点) CRM应用程序，它使用spring集成框架(v2.2.0)在执行操作时发布事件，例如创建请求、创建客户等。目前，这些事件只是转到空通道，但我想开始将它们转发到运行在同一网络上的Apache Kafka实例。从那里，我想对数据进行进一步的处理和分析，以使用其他组件创建实时报告。
我看过spring- integration -kafka项目，但它似乎与应用程序使用的spring集成版本不兼容(我无法升级)。
我认为我将这些活动带到Kafka的选择是：
1)向本地文件系统发送事件，并让Kafka从本地文件系统拉取数据。
2)将事件发送到中间JMS队列，并让Kafk
浏览 13提问于2017-08-11得票数 0
回答已采纳
1回答
有一个将表数据从BigQuery复制到CloudSql的管道。 云SQL表的创建发生在数据流之外。 现在我们需要在数据流中创建表。 我有表格要创建在GCS存储桶中作为.sql文件。 下面是将表从BQ复制到sql的代码片段。 p.apply(BigQueryIO.readTableRows()
.from(source_table)
.withTemplateCompatibility()
.withoutValidation())
浏览 75提问于2021-09-20得票数 1
回答已采纳
我想创建一个Storm Spout，它从Apache Kafka的主题中读取数据，并将这些数据发送到连接到MongoDB的Storm bolt，并查询我从Kafka收集的消息以丰富数据。例如:我有一个personID (我是通过Kafka发来的消息得到的)，我想使用这个personID查询MongoDB中的个人地址。在我的MongoDB集合中，每个文档都有personID和地址。
有人能给我举个例子吗？一个使用Spark-streaming的例子也会很棒。
浏览 0提问于2018-04-18得票数 0
我有以下设置：
几个Spring服务，其中最显著的是spring-cloud-starter-zipkin和spring-cloud-stream-binder-kafka依赖项。
运行openzipkin/zipkin:2.8停靠映像的Zipkin服务器
我看到服务中的痕迹进入了" zipkin“主题，zipkin选择了这些跟踪，我可以在zipkin ui中查看它们。
乍一看，一切似乎都还好，特别是在我的服务之间的rest调用中，但是我刚刚看到，它并不适用于我自己用于服务之间异步通信的消息(我使用spring云流来实现这一点)。
我可以看到来自TraceChann
浏览 0提问于2018-06-11得票数 0
回答已采纳
我想使用Kafka将数据从本地流式传输到云(S3)。为此，我需要在源机和云上安装kafka。但我不想把它放在云端。我需要一些S3连接器，通过它我可以与kafka连接，并将数据从本地传输到云。
浏览 1提问于2017-03-29得票数 2
我有一个场景，几条消息必须通过服务层中REST的触发器发布。
此服务还具有db操作(插入、更新)。这里的要求是，如果有网络问题导致发布者无法发布，或者kafka broker不可用时，我们希望回滚所有东西，包括数据库，并通过API响应通知用户它失败了。
Q1：是否有可能通过启用Kafka事务来实现需求？
根据我的理解，默认情况下，同一事务数据库将首先提交，然后由kafka跟踪，但我不确定的是，如果kafka没有提交，我们将完全失去消息，数据库也不会回滚。
我用以下设置对一个简单的spring引导项目进行了一些测试：
2020.0.3org.springframework.cloud.strea
浏览 5提问于2021-07-25得票数 0
我使用的是最新的Greenwich.SR1，包括spring云流(version: Fishtown.SR2)和本地启动的kafka客户端版本:2.2.0，使用kafka_2.12-2.2.0.jar
我想使用最新的kafka客户端2.1或更高版本的spring云流，因为它包含一些重要的bug修复。但是当我运行我的spring应用程序时，它的日志上写着
INFO 37812 --- [main] o.a.kafka.common.utils.AppInfoParser : Kafka version : 2.0.1
如何与最新的kafka客户端一起使用spring云流？我想使用max.task
浏览 0提问于2019-05-21得票数 0
为什么你用卡夫卡来谈论数据流。
然而，例如，在REST API方面，我从未听说过数据流这样的东西。
也许有人能告诉我术语数据流在Kafka中的真正含义。顺便说一句，我知道在Kafka中有生产者和消费者。生产者将数据发送到代理，然后代理将其发送给消费者。
浏览 0提问于2021-05-02得票数 1
目前我没有使用spring cloud dataflow，尽管我在我的应用程序中创建任务并通过命令行运行它们。目前，我正在考虑通过kubernetes迁移到spring云数据流。所以我首先关心的是，我如何重用我当前的代码？数据流部署程序使用哪个命令来运行任务？
浏览 6提问于2020-08-19得票数 0
当我从我的webapp中调用spring云数据流服务器-本地服务器时，我得到了以下错误：
XMLHttpRequest无法加载 。对飞行前请求的响应不会通过访问控制检查:请求的资源上没有“访问-控制-允许-原产地”标题。因此，'‘源是不允许访问的。响应具有HTTP代码403.
我该怎么调整呢？
帮帮忙，谢谢！
浏览 5提问于2017-03-09得票数 1
回答已采纳
为了表明我的意思我做了一个简单的项目。
依赖关系：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.kafka&l
浏览 6提问于2020-11-01得票数 1
回答已采纳
我有多个弹簧引导应用程序，与卡夫卡经纪人一起实现春云流。我想知道我是否可以停止或禁用spring云流或kafka broker连接来启动应用程序。
浏览 3提问于2020-01-28得票数 8
1回答
Spring数据流支持批处理吗？
、、、、
我们正在探索各种编程/库选项(在Java方面)，以便更快地进行批处理，并能够部署在云上。我们遇到了Spring /XD/cloud数据流。从对文档的快速回顾来看，我们无法评估Spring是否也具有spring将提供的所有批处理功能。例如，这里是SPring批处理文档()所说的："Spring提供了处理大量记录所必需的可重用函数，包括日志/跟踪、事务管理、作业处理统计、作业重新启动、跳过和资源管理。“
如果有人对春云数据流中的批处理功能有任何了解，请在这里发帖。非常感谢！
浏览 4提问于2016-05-18得票数 4
回答已采纳
1回答
我目前正在尝试编写一个适配器，它将使用来自ActiveMQ的消息并将其发布到Kafka。
我正在考虑使用spring集成来集成这两个消息传递系统。
我的问题是，我的应用程序不会维护模型的注册表，许多应用程序将使用这些模型将记录发布到activeMQ。我想要接收这些javax消息，并想执行一些转换，比如将jmscorrelationId添加到kafka消息中。
ALso，另一个要求是仅当kafka发送/发布成功时才向活动mq发送确认。
是否可以使用spring集成将ack发送回activemq？
spring集成是个不错的选择吗？
请注意，我的技术架构师不赞成使用Camel/Mule。此外，他不
浏览 10提问于2017-07-05得票数 0
回答已采纳
这是我的制片微服务kafka配置：
@Configuration
public class KafkaProducerConfig {
@Value("${spring.kafka.bootstrap-servers}")
private String bootstrapService;
//producer factory
@Bean
public ProducerFactory<String, Object> producerFactory (){
Map<String, Object> c
浏览 11提问于2022-03-15得票数 0
回答已采纳
我正在设计一个Java微服务中间件，它将部署在云计算提供商(最有可能是Azure)中。我正在考虑的技术堆栈由以下框架/库组成(不包括数据库)：-Spring -Spring云-Spring云配置服务器-Spring云侦察-Netflix Ribbon -Netflix Eureka -Netflix Zuul -Netflix Hystrix -Kafka Apache
我的问题是，是否有可能避免使用Spring Cloud packages系列，以及Netflix系列，并将它们的功能替换为Azure中可用的服务。
浏览 2提问于2019-01-26得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
