《stream》专题

我有一个想要处理的对象列表，而Java8流API看起来是最干净、最易读的方法。 但是我需要在这些对象上执行的一些操作包括阻塞IO（比如读取数据库）--所以我希望将这些操作提交到一个包含几十个线程的线程池中。 一开始我想做一些类似的事情： 和仅用于重新抛出已检查的异常。 但是，显然，对的调用将阻塞流的线程，直到对给定对象的查询完成为止，并且流在此之前不会进行。因此一次只处理一个对象,线程池没有意义。

我知道总是打印第一次出现的索引。我如何打印所有的索引？

所以这是我的配置： 我要把商店弄成这样： 这将失败： 这里讨论了一个类似的问题：Kafka Streams 2.5.0 requires input主题看起来这将在kafka-streams 2.5.1和util中修复，那么设置比声明虚拟流更好。

我有一个KStream x KStream连接，它正在中断，但有以下例外。 尽管如此，我尝试将属性设置为，即30MB。我不希望推荐记录超过这个限制。但是，代码还是崩溃了。 我不能更改Kafka集群中的配置，但如果需要，我可以更改Kafka中相关主题的属性。 有人能建议我还能试试什么吗？ 如果什么都不起作用，我愿意忽略这样的超大信息。但是，我不知道处理这个的方法。 执行连接的代码如下所示。 是连接的

我在一个输入主题上构建KTable，并且在两个Kafka Stream应用程序实例上加入KStream。 KTable的输入主题已经是一个日志压缩主题。因此，当我的一个应用程序实例关闭时，通过读取input log compacted主题，另一个实例状态存储似乎会用整个状态刷新。 所以不需要为我的KTable存储启用日志记录（更改日志）？ 我的源输入日志压缩主题可能有数百万条记录，所以如果我在KT

我是gRPC的新手，正在编写一个应用程序，其中8个客户端每秒向gRPC服务器发送50k个异步请求。我知道我应该为每个客户端重用该通道，但是流观察者怎么样？现在每次客户端发出请求时，我都会创建一个新的流观察者。这会是瓶颈吗？如果有任何回复，我将不胜感激！

我当前的方法是从获取传入消息，将其拆分为N个消息（其中N是数组的长度），对执行左联接以添加项目描述，然后将结果流分组到（丰富的拆分消息的关键字）上，以重构完整消息。 问题是描述可能会延迟几秒钟到达，所以在一些罕见的情况下，我得到的重构消息的条目比原始未充实的少。 我已经在自定义联接示例中看到了这种方法。对我的案子来说挺好的，可惜不完全适合。的确，在我的案例中，如果缺少单个项目的描述，那么完整的消息

给定以下代码： 在reduce语句之后我需要什么才能看到reduce的结果？如果一个值被推到输入，我不希望看到任何东西。如果推送具有相同键的第二个值，我希望还原器应用（它确实应用了），并且我还希望还原的结果继续到处理管道中的下一个步骤。正如所描述的，我没有在管道的后续步骤中看到任何东西，我不明白为什么。

首先，我有下面的发票清单。每个列表对象都有一个零件号、一个描述、数量和一个价格。 我将其映射到数量上，并将其排序到数量上，得到以下结果： 但是我如何在上进行映射，以便在我的结果中显示在所显示的数量前面？我不能这样做：

在Java8中，使用两个返回的方法扩展了集合接口:（返回顺序流）和（返回可能并行的流）。Stream本身也有一个方法，该方法返回一个等效的并行流（或者将当前流改为并行流，或者创建一个新流）。 重复有明显的缺点： 如果现有实现具有一个具有不兼容返回类型的类似名称的方法，则向接口添加方法可能会发生冲突。在stream（）的基础上添加parallelStream（）会使风险增加一倍，但收益很小。（请注意

我是Java泛型的新手。我有两个不同类型的列表，分别是Object和Integer，我想写一个泛型方法来获取列表，并打印出列表中包含的元素。例子 输出：1[2,3,4,5][6,7] 和 1 2 3 4 5 6 7 8 但我只想从两个列表中打印出1,2,3,4,5,6,7,8。

我是java函数编程的新手，不知道如何编写代码来避免（例如）此操作中的NPE： 我在这里的目的是在列表中查找最新对象的时间戳。关于如何更好地收集最后一个元素的建议非常受欢迎，但我在这里的主要问题实际上是为什么这有效。 文档显示，如果归约的结果为空，该函数将抛出< code > NullPointerException : http://docs . Oracle . com/javase/8/do

假设数据采集对象如下所示 我需要尝试使用java lambda函数在引擎匹配时获取匹配的品牌对象。 现在，如果发动机类型匹配，我需要获得品牌名称。例如，如果搜索引擎1，则需要返回Honda对象。 下面是代码示例:类Vehicle: 类别品牌: 类车： 类引擎： 班级主修： 以上是我尝试的代码。之前，我的目标是使用授权子对象列表中的关键字进行过滤。 现在，我使用它作为一个键，以父对象或品牌对象作为值

我有一个列表和另一个数组列表。我想区分它们并返回新的数组列表。 我想返回ArrayList。我在返回列表（Collectors.asList等）方面没有问题 问候

当从shell/data flow UI部署流时，有没有什么解决方法不使用git build pack 以下是https://github.com/cloudfoundry/java-buildpack.git的错误消息：克隆git repository失败