《stream》专题

你能帮助我如何使用Kafka流实现这一点吗？ 场景：将订单数据的所有发票分组。在实时流媒体中，可能会延迟接收发票。因此，我们希望在加入之前等待20分钟将所有发票分组。 示例：订单“x”有3张发票，预计将在20分钟内收到。 预期输出：订单和3张发票应作为输出主题中的单个数据提供。 我们有下面的拓扑结构来实现这一点。 > 我们正在根据订单密钥对发票进行分组。我们设置了20分钟的翻滚窗口 将订单数据与生

我试图加入2 KTables。 合并功能非常简单，我只是将值从一个bean复制到另一个bean。 但由于某些原因，join函数在单个生成的记录上调用了两次。请参阅下面的流媒体/制作人配置 生产者配置- 接下来，我将提交每个流的单个记录。两个记录具有相同的密钥。我希望收到一条记录作为输出。 但是ValueJoiner触发了2次，我得到了2条相同的输出记录，而不是一条。在触发时间内-两个流中的值都存在

我的流应用程序只是从一个记录主题中物化一个KTable。与100K记录在主题，没有问题。但是，由于主题中15M记录，一旦我们得到几百万条记录，实例将崩溃，出现以下异常： Thread“公司-de1f21f9-b445-449e-a59b-5e0cecfa54d1-StreamThread-1”组织中的例外情况。阿帕奇。Kafka。溪流。错误。StreamsException:任务[0_0]中止发送

我正在构建一个非常简单的KafkaStreams演示应用程序，以测试用例。 我无法升级我正在使用的Kafka broker（当前版本为0.10.0），并且有几条消息是由0.10.0之前的生产者编写的，因此我使用自定义时间戳提取器，我将其作为默认值添加到主类开头的配置中： 当从我的源主题消费时，这非常好。但是当使用聚合运算符时，我遇到了一个异常，因为当从内部聚合主题消费时，使用了的实现而不是自定义实

我有一个类，有多个成员。 还有一个类，只有两个属性： 我需要遍历类中的各种列表，并创建类对象，并添加到这样的列表中： 这里重复了if和for循环。 如何使用Java流实现这一点？ 注意：类，和之间没有关系，也没有公共接口。

我们可以使用StreamApi将上面的字符串转换为字符流吗？

我想知道是否有一种方法可以直接在Java中通过使用stream（）.filter（）过滤出单个元素，而不需要创建列表和获取0索引。

我希望得到以下内容:，然后:。因为我们首先遍历1到20之间的所有数字，所以只筛选出那些可被3除的数字，然后遍历这个新的并找到那些可被5除的数字。 但相反，我得到了以下输出: 它看起来没有检查所有的数字。此外，它看起来只检查可被3除的数字。

我想把列表转换成地图使用作为关键值只有两个字符串值。然后作为值，从输入列表中只列出包含奇数或偶数索引位置的元素的字符串列表。以下是旧的时尚代码： 如何使用流将此代码转换为Java8以获得此结果？ 我目前的混乱尝试需要修改列表的元素，但肯定是更好的选择。 或者也许有人帮我解决这个不正确的问题？ 返回以下内容：

我尝试了这种方法，但得到了强制转换异常，不能将字符串转换为整数。

在我的应用程序中，我使用下面的代码使用带有Stream_Notification的MediaPlayer播放一个简短的通知声音。问题是，当应用播放通知声音，同时音乐播放器应用在后台播放音乐时，通知声音会中断（暂停）音乐播放。如何才能让自己APP的通知声音与背景音乐播放同步播放？多谢了。

我希望将转换为给定，其方式是由的行组成。此外，一行不应立即读取，而仅在需要时才读取。

Java 8流#findFirst（）是一种短路终端操作。这意味着一旦找到元素（通常与filter（）操作一起使用），它将停止生成流。 但是，我想知道它是否会在平面图创建的流上短路。即它会短路在平面图操作中创建的流。 换句话说，哪种代码更有效(在流中生成的元素更少): 示例1（使用平面图）： 示例2（无平面图）：

我有一个这样的结构： 和看起来像这样 这不是最好的设计-我知道，但我没有能力改变这个设计。 我正在尝试找到一种方法，将此结构扁平化为单个，并找到一个itemTag 但这仅搜索项目列表的一个级别。如果我想更深入，我可以简单地做： 这很好。但我正试图找到一种更具可扩展性的方法来实现这一点，它可以像嵌套列表一样深入。有没有有效的方法来做到这一点？

我们有几个微服务使用spring boot和spring cloud Stream Kafka binder在它们之间进行通信。 偶尔，我们会观察到使用者接收到的重复消息的突发事件--通常是在第一次消费和处理（成功）之后的几天。 虽然我知道Kafka并不保证一次性交货，但考虑到经纪人和服务公司的日志中都没有再平衡事件或任何“可疑的”activity，这看起来还是很奇怪的。由于使用者正在与外部API