《stream》专题
-
为什么在Kafka Streams API中没有异步/非阻塞支持？
我想知道为什么在Kafka Stream API中没有通过简单的回调或Java的CompletableFuture或Scala Futures提供非阻塞支持。 我确实理解需要维护分区中的排序，但是在跨分区中，我看不出有什么理由通过阻塞一个昂贵的资源来实现排序：线程。 例如，当我让我的Kafka Streams应用程序调用外部服务时，例如在mapValues中运行在一台服务器上，并且我有超过数千个分
-
如何在Android中使用HTTP POST与“application/octet-stream”？（微软认知视频）
我想使用Android中的视频认知服务。Microsoft提供的示例在C#中使用。视频功能是向服务器发送URL，所以我认为在Android中使用HTTP POST发送URL是可能的。 http://ppt.cc/v1pia
-
stream的“max”如何接受param like“Integer::compare to”[duplicate]
接受类型的参数，其中包含方法；比较方法接受两个参数，并返回一个。所以我们可以使用一个方法将引用为方法的参数；但是只接受一个参数，与方法的参数数量不匹配，那么为什么它也可以用作的参数呢？ 那是我的代码：
-
在Kafka Streams应用程序中启动新线程（使用编程方式）是否可取？
我们正在开发一个使用低级别处理器API的Kafka流应用程序。 根据Kafka的文档，所有线程和并行性都由流线程和流任务处理。使用主题上的分区，并行性也是可伸缩的。 我尝试了最基本的代码，但不能确定它是否介入了Kafka提供的自动功能。例如自动提交偏移量、超时等。 还是坚持Kafka streams已经提供的默认行为并利用stream线程快速处理数据总是更好？
-
使用kafka streams processor api处理失败消息
使用kafka流处理器api 场景：流处理器（使用kafka流处理器api实现）从源主题读取数据，并基于某些业务逻辑将数据写入目标主题。
-
如何在Spring-Cloud-Stream中使用kafka流程拓扑内的交互查询？
是否可以在Spring Cloud中使用@EnableBinding注释的类流或在方法中使用@StreamListener使用交互式查询（InteractiveQueryService）？我尝试在提供的KStreamMusicSampleApplication类和process方法中实例化ReadOnlyKeyValueStore，但它始终为空。 我的@StreamListener方法正在监听一组
-
Kafka streams窗口批处理
来自火花流背景-掌握Kafka流。 我有一个简单的Spark流媒体应用程序, 并返回该分钟内每个用户的最新事件 示例事件类似于 我感兴趣的是这将如何在Kafka流中工作，因为似乎每个事件都有一个输出--当我的用例是减少流量时。 从我到目前为止的阅读来看，这似乎不是直接的，您将不得不使用处理器API。 理想情况下，我希望使用DSL而不是处理器API，因为我刚刚开始研究Kafka流，但似乎我必须使用处
-
Kafka Streams API：KStream到KTable
我能做到写作和阅读的中间主题： 有没有简单的方法从中获取？这是我第一个使用Kafka Streams的应用程序，所以我可能错过了一些明显的东西。
-
Kafka Streams GlobalKTable主题需要与KStream主题相同数量的分区吗？
我们希望在Kafka streams应用程序中使用GlobalKTable。输入主题（ktable/kstream）有N个分区，并且GlobalKTable将用作流应用程序中的字典。 GlobalKTable的输入主题必须与其他输入主题（它们是KTable/KStream的源）具有相同数量的分区吗？ 据我所知，答案是否定的（它不受限制，主题也可能有M个分区，其中N>M)，因为GlobalKTabl
-
如何向Kafka Streams DSL处理器添加自定义StateStore？
对于我的一个Kafka streams应用程序，我需要同时使用DSL和处理器API的特性。我的流媒体应用程序流是 聚合之后，我需要向接收器发送单个聚合消息。因此我定义拓扑如下 知道这里出了什么问题吗？
-
Spark Streaming和Kafka：一个集群还是几个独立的盒子？
我要做一个关于使用火花流Kafka集成的决定。 一个Kafka主题和一个星火集群。 几个Kafka主题和几个独立的Spark盒（每个主题有一台带有独立Spark集群的机器） 几个Kafka主题和一个星火集群。 我很想选择第二种方案，但我找不到人谈论这样的解决方案。
-
Jersey中的StreamingOutput是否已缓冲？
我有两个问题关于StreamingOutput在泽西： 1） 它已经被jax-rs运行时缓冲了吗？我见过一些例子，在重写write（）方法时，从OutputStream对象创建BufferedWriter。但我想知道这是否真的有必要。 2） Jersey或jax rs运行时是否在流完成后关闭OutputStream对象？ 谢谢 格格
-
使用多个Kafka流进行Spark Streaming
我使用以下代码创建kafka流： 我给每个流不同的组ID。当我运行应用程序时，只接收到部分kafka消息，并且执行程序在foreachRDD调用中挂起。如果我只创建一个流，一切正常。日志信息没有任何例外。 我不知道为什么应用程序卡在那里。这是否意味着没有足够的资源？
-
Java stream toArray（）转换为特定类型的数组
也许这很简单，但实际上我对Java8特性一无所知，不知道如何实现这一点。我有一个简单的行，包含以下文本： “密钥,名称”
-
为什么stream parallel（）不使用所有可用的线程？
output指示在1s暂停之前执行16个流元素，然后再执行16个元素，依此类推。因此，即使forkjoinpool是用100个线程创建的，也只有16个线程被使用。 当我使用超过23个线程时，就会出现这种模式：