《stream》专题

我使用Spring Cloud方法来构建一些应该相互交互的微服务。对于微服务之间的消息传递，我打算使用RabbitMQ和Spring AMQP，但在我看了Spring Cloud Stream之后，我感到迷失了。在我看来，Spring Cloud Stream是下一个抽象级别（可能太强了，但您应该会得到整体印象），具有许多非常有用的功能。所以我想知道为什么有人会使用Spring AMQP进行新开发

我正在做一个尝试采用消息驱动框架的项目。（不同的独立组件与消息代理路由的消息通信） RabbitMQ最终被选为经纪人。 对于框架，起初我们尝试使用Spring Cloud Stream，但当我们尝试利用Rabbit特性时，例如：Exchange、路由密钥、备用交换......我们发现很难在Spring Cloud Stream中使用它们。 所以我的问题是： 我必须使用SpringRabbit（或者

我正在使用Spring云流（SpringBoot）与RabbitMQ实例通信。 该项目可以通过AMQP连接到RabbitMQ，但不能用于STOMP。任何人都知道：是否支持stomp以及如何配置？（我的RabbitMQ已打开61613端口） 应用程序。yml文件如下：

从这个问题开始，AWS DynamoDB流进入红移 DynamoDB-- 如何配置我的Kinesis函数以获取Lambda函数源？ 我创建了一个DynamoDB表（购销），并添加了DynamoDB流。然后，我配置Lambda函数来拾取DynamoDB流。我的问题是如何配置Kinesis以获取Lambda函数源？我知道如何配置Lambda转换，不过我想把它作为源代码。不确定如何配置下面的直接输入源。

使用的平台：库伯内特斯。 我对Spring cloud stream url有问题。我正在使用spring cloud stream启动我的spring cloud任务。流部署在kubernetes平台中。流包含http kafka作为源，TaskLaunceKafka作为接收器。我使用http kafka kubernetes服务url来启动任务。Kubernetes服务url在每次部署后都会发

我试图通过火花流（jdbc）将avro文件的数据集加载到Teradata表中。配置设置正确，加载在一定程度上成功（我可以验证数据行是否已插入表中），但中途我开始出现异常，加载失败。堆栈跟踪如下。关于可能导致这种情况的原因有什么线索吗？

正如我所看到的，我们可以从Microsoft Graph API访问一个驱动器和团队的内容。类似地，是否有任何Microsoft Graph API可用于访问用户在Microsoft Streams中发布的内容/视频。 转介医生：- > https://docs.microsoft.com/en-us/graph/api/drive-get？view=graph-rest-1.0&tabs=htt

我已经讨论了前面的几个问题，比如java stream中的遭遇顺序保存、Brian Goetz的回答，以及javadoc for stream。reduce（）和java。util。流包javadoc，但我仍然无法理解以下内容： 以这段代码为例： 为什么减少总是保持遭遇顺序？ 到目前为止，经过几十次运行，产量是相同的

我看不出我的流api逻辑有什么问题 [错误]mystuff/MandantContentFetcher。java:[67,23]不兼容的类型：java。无法将lang.Object转换为java。util。列表 这是我的stream方法： 其中使用此方法引用： 他为什么看到一个物体？第二个映射中的方法引用确实返回MandantLinkCheckerEntry。我还假设collect确实创建了一个列

对于这个用例，我应该使用Kafka Consumer API还是Kafka Streams API？我有一个话题与一些消费群体消费它。本主题包含一种类型的事件，它是一个内部埋藏了一个类型字段的JSON消息。一些信息会被一些消费者群体消费，而另一些消费者群体不会消费，一个消费者群体可能根本不会消费很多信息。 我的问题是：我是否应该使用消费者API，然后在每个事件上读取type字段，并删除或处理基于t

我有和如下代码所示： 我尝试用< code>HashMap值替换该字符串，但这不起作用，因为< code>test是最终的，不能在< code>forEach的主体中重新分配。 那么有没有用Java 8 Stream API将< code>String替换为< code>HashMap的解决方案呢？

我想从excel（.xlsx）文件中读取超过60万行。 我使用的是ApachePOI和xlsx拖缆。 Apache poi版本为3.15，因为xlsx streamer在上述版本中不支持 我只想迭代特定的列。我尝试过的是： 我得到这个例外，几乎没有警告 第35行是

我们使用的是基于Spark Streaming接收器的方法，我们刚刚启用了检查指向来解决数据丢失问题。 火花版本是，我们正在接收来自Kafka主题的消息。 我在内部使用了，方法，所以它抛出了不可序列化的异常。 我试图扩展可序列化的类，但仍然是相同的错误。只有当我们启用检查点时，才会发生这种情况。 错误日志： 2017-02-08 22:53:53250错误[驱动程序]流媒体。StreamingCo

的方法引用之一 > ，它不接受参数，基本上是函数接口。[1] ，它接受类型的参数，是函数接口。[1] 是有效的。那么函数如何知道如何将选项（1）中的函数应用于流对象，但将流对象传递给选项（2）中的函数？ [1]https://docs.oracle.com/javase/8/docs/api/java/util/stream/package-summary.html

我正在运行一个SQL消费者来读取表中的更改，这很好。然而，有时更改会大量发生，然后我的查询会因为内存溢出错误而中断，这可能是你所期望的。 不幸的是，我被困在Camel 2.17.6上，因此SQL组件的StreamList选项不可用。（尽管根据Camel SQL，为什么使用StreamList似乎会加载所有ResultSet？由于Spring JDBC的限制，它不能作为流列表使用。） 因此，我已经使