如你所想，我们最有价值的资产是我们客户的数据，作为一家SaaS公司，避免通过我们的Kafka管道处理混合租户数据批次对我们来说至关重要。那么我们如何在使用spring云数据流的同时创建一个特定于宗旨的Kafka绑定器。
浏览 11提问于2021-06-03得票数 0
2回答
我正在开发一个spring引导应用程序，这个依赖库仅用于消费数据并将数据推送到数据库。
卡夫卡( spring-cloud-stream-binder-kafka )或卡夫卡(spring)
浏览 9提问于2022-04-27得票数 -2
我遇到的问题是使用(SCDF)通过环境将数据移动到正确的位置。情况如下：
我有一个生产版的卡夫卡，我只能订阅(只读)。(3节点集群: node 1:9092，Node 2:9092，Node 3:9092)i有一个运行在Kubernetes集群中的SCDF实例，该集群使用RabbitMQ主干(全部在一台服务器上)i有一个节点卡夫卡服务器，用于另一家公司获取数据(ssl受保护)。在查看SCDF时，我没有看到一种将Kafka定义为源并将其
浏览 3提问于2021-06-03得票数 0
在我们的项目中，我们使用spring-cloud-starter-stream-kafka来消费来自卡夫卡的消息，在添加了@ComponentScan for "org.springframework.cloud.stream.binder.kafkaorg.springframework.cloud.stream.test.binder.TestSupportBinder (org.springframework.cloud.stream.binder.kafka.Kafka
浏览 27提问于2022-05-18得票数 1
回答已采纳
1回答
使用spring云数据流运行我的spring云流应用程序的最简单方法是什么？我的想法是创建自定义的源代码，使用kafka绑定器和接收器作为预构建的启动程序，文件。我尝试创建可执行的jar，并使用dataflow shell将其注册为源代码，但这根本不起作用。我已经在跟踪这个了。
浏览 2提问于2016-07-27得票数 0
回答已采纳
是否可以为Apache Kafka配置Spring Cloud DataFlow的身份验证？我可以在哪里看到示例？
谢谢。
浏览 15提问于2016-08-03得票数 0
2回答
运行时配置更新
、、、、
我使用Spring云流和Kafka绑定器来使用SASL连接到Kafka集群。SASL配置如下所示：spring.cloud.stream.kafka.binder.configuration.sasl.jaas.config=SASL_SSL
我想以编程方式
浏览 3提问于2021-03-26得票数 0
2回答
我正在使用docker部署spring数据流服务器。通过部署两个spring引导应用程序作为源、处理器和接收器，我在数据流服务器中创建了一个数据处理管道。为了访问每个服务的日志，我要么必须从停靠器( bash )内部跟踪它，要么我必须将它从docker容器复制到本地磁盘。
我想使用log4j-kafka附录将这些日志推送给kafka，以便以后进行
浏览 2提问于2017-05-18得票数 0
回答已采纳
我是否需要自己在主服务器上安装Spring数据流实例，还是将其作为部署的一部分“自动”安装？我遵循了指南，尽管删除了MySQL的所有配置。也许这是必需的。虽然我有点卡住了，因为它只是没有分配外部IP，我不知道为什么，如何调试，以及我是否错过了安装一些必要的组件。
编辑:为了澄清，我在运行时看到一个scdf服务条目。
浏览 13提问于2016-11-20得票数 0
是否有任何属性可以启用/禁用春云流中的kafka绑定。我想把卡夫卡活页夹包含在pom.xml，但想禁用/启用卡夫卡绑定在生产中可选。我们通过拥有单独的dao层和控制器层以及保持一个公共服务层，为两者维护相同的源库。其想法是部署从同一个源库生成的两个版本的应用程序(当前版本和迁移版本)，并并行运行它们以进行验证。当我们这样做时，当前版本不需要知道任何kaf
浏览 0提问于2018-11-21得票数 1
我不确定我是否理解了Spring Cloud Data Flow (SCDF)和Apache Kafka Broker(及其相关的Zookeeper)之间的关系。我阅读了一些文档，并观看了一个关于Spring Cloud数据流(SCDF)的网络研讨会。我了解不同的绑定选项(RabbitMQ，Kafka，...)用于此框架中不同微服务之间的通信。SCDF“只是”使用Kafka
浏览 0提问于2017-10-25得票数 1
到目前为止，我一直在研究spring云模式注册表和confluent模式注册表。我可以看到一些区别，比如spring云模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而confluent模式注册表保存在kafka topic中。对于spring云模式注册表，这种方法有没有性能影响？据我所知，即使数据被保存在主题上，如果是合流的情况下，查询仍然会有延迟。
浏览 26提问于2021-06-29得票数 0
1回答
在Spring Cloud Bus ()的文档中，提到了以下内容
总线启动器包括兔子和Kafka，因为这是两个最常见的实现，但是Spring非常灵活，绑定器将与spring云总线结合使用。在我的项目中，我们不能为兔子或卡夫卡维护另一个基础设施，因此我想使用spring-cloud-stream-binder-aws-kinesis ()和<em
浏览 6提问于2017-11-28得票数 1
回答已采纳
我可以使用spring-cloud-dataflow(kubernetes)来执行递归任务吗？我需要根据当前结果创建流的新实例(递归)。我需要任务的分布式处理。据我所知，数据流使用自己的消息代理(兔，kafka)。我是否需要安装另一个代理，或者我可以在数据流代理中创建队列？3)流与任务？
thx
浏览 2提问于2016-11-28得票数 0
我已经用kafka绑定器创建了一个简单的spring cloud streaming "source“& "Sink”应用程序，并在SCDF (Spring Cloud Data Flow)中注册了jars在SCDF ( source-app | sink-app )中创建流，并成功部署流。 当我尝试调用source时，source产生的消息没有写入Kafka topic。topic是以“steam-nam
浏览 10提问于2019-09-17得票数 0
我使用过spring cloud data flow、rabbitmq和kafka，但我想知道是否可以使用google pub/sub安装scdf。我不想创建一个流(新的应用程序，spring云流)，它的源或宿都是gcp，我想让google pub/sub over spring cloud数据流服务器作为一个中间消息传递代理。
有什么建议吗？
浏览 1提问于2019-12-30得票数 1
看看使用绑定(functional )的项目，我遇到了两种风格-- KStreams和反应性管道Flux<Message<T>>。它们作为一个想法有些重叠，但只是部分地重叠。卡夫卡世界中Flux的特征是什么？这是另一种"KStream"，一种“耐久的反应流”吗？它的使用是否保证不滞后，或至少最小，因为背压？
浏览 4提问于2022-09-14得票数 0
回答已采纳
我的问题是，我是否可以在关键的云创建环境上部署星火应用程序。如果有的话，你能提供例子吗？
谢谢
浏览 3提问于2017-09-12得票数 0
回答已采纳
2回答
我正在将我的一些应用程序转移到微服务领域。一个示例服务是RSS爬虫，它使用向Kafka发送项目。我还看到了Spring数据流，它使用Spring集成和Spring批处理。如果我使用Spring数据流，我是在每个微服务中使用这个，还是将它用作微服务之间的编排？
我正在尝试理解引入Spring数据流的好处，而不是使用Spring来保持微服务尽可能轻。
浏览 0提问于2018-04-19得票数 11
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
