《流程》专题

如何解决它。请帮助我。提前谢谢。

我正在使用NIFI1.11.4构建一个数据管道，其中IoT设备以JSON格式发送数据。每次从IoT设备接收数据时，都会收到两个JSONS； JSON_Initial 和JSON_FINAL

在Spring Boot应用程序中，我试图配置Kafka流。用简单的Kafka主题，一切都很好，但我无法得到工作SpringKafka流。 这是我的配置： 我想创建一个基于主题的流。应用一个简单的转换并将此流中的消息发送到test主题。 我向发送以下消息，其中是我自己的复杂类型，但是我现在不知道如何将它转换为中的，以便能够在中使用它。 请建议如何使其工作。

将此流收集到列表中 正如我所看到的，infinity循环有一些问题，所以peek（）打印范围内的数字(12，99)，这是可以的，但之后它再次打印范围内的数字(11，98)，等等，你能解释一下我在哪里犯了错误吗？

我正在编写一个MMO塔防游戏（客户端服务器架构）。由于作弊保护，服务器需要有逻辑。但我有真正的设计问题。假设 10 个人互相进行死斗，每个塔射都需要计算并发送给玩家。当许多塔建成时。（如 10 名玩家 * 10 塔 = 100 塔） 流量非常高。（一个播放器每秒导致多条消息）如何解决这个问题？ 服务器是用Java编写的（Smartfox 2x）客户端是用C#编写的（Unity 3d） 先谢谢你。

我想用java代码调用一个外部程序，然后Google告诉我Runtime或ProcessBuilder可以帮助我完成这项工作。我试过了，结果发现java程序无法退出，这意味着子进程和父进程都将永远等待。它们要么挂起，要么陷入僵局。 有人告诉我原因是子进程的缓存太小了。当它试图将数据返回给父进程时，但是父进程没有及时读取它，然后他们两个都挂起了。所以他们建议我叉一个线程来负责读取子进程的缓存数据。我

谢谢，马尔科

我试图在我的应用程序中集成spring cloud stream kinesis，但我找不到手册中的所有配置选项。我看过这个链接： https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis/blob/master/spring-cloud-stream-binder-kinesis-docs/src/main/as

我正在使用SpringCloudGatewayHoxton。M1发布以实现API网关。我可以看到以下格式的日志- 我也可以在下面的访问日志中看到- 从这看来- 下游耗时约200毫秒 没有配置全局筛选器。此外，路由仅使用重写路径和添加请求头筛选器。下面是路线。它还使用redis的速率限制功能。 当下游只需要200毫秒时，SpringCloudGateway需要的255毫秒看起来有点高。 我已经为网关

我正在使用Flume 1.6.0-cdh5.9.1使用Twitter源流式传输推文。 配置文件如下所示: 对于Cloudera. jar依赖项，我使用Maven使用以下依赖项构建了： 现在，当我运行Flume Agent时，它成功启动，连接到Twitter，但在最后一行（接收状态流）后停止： 在最后一行之后什么都没有发生。它不会终止，不会流式传输任何东西。我看了一下HDFS位置，那里没有创建任何东

还在学习Java8。我的代码看起来像： 上述代码不起作用，因为peek（）无法访问主流变量，即map（）中使用的电子邮件。我该如何解决这个问题？

我遵循火花流水槽集成的指导。但我最终无法获得任何事件。（https://spark.apache.org/docs/latest/streaming-flume-integration.html）谁能帮我分析一下？在烟雾中，我创建了“avro_flume.conf”的文件，如下所示： 在文件中，123.57.54.113是本地主机的ip。 最后，根本没有任何事件。 怎么了？谢谢！

我正在尝试使用python库Tweepy来传输twitter数据。我设置了工作环境，谷歌了一下这些东西，但是我不知道它们是如何工作的。我想在python (tweepy)中使用spark streaming(DStream-Batch processing)。我至少经历了以下环节: < li >如何获取tweepy中某个位置的特定标签的推文？ < Li > http://spark . Apach

我要用Kafka流计算平均值。所以我做了一个有状态的操作，聚合，需要创建一个状态存储，但是这种情况不会发生。 这里是平均值的函数： 以下是例外情况： 问题是基本目录不存在，但我希望kafka流在必要时创建目录。 编辑 ----- 我注意到，如果我有1个处理器，使一个变量的平均值没有问题，但如果我有2个处理器是。 1个处理器的配置文件： 2个处理器的配置文件： 现在我启动处理器： 类型元组包含配置文

我发现这个带有数据流的示例https://github.com/GoogleCloudPlatform/cloud-bigtable-examples/blob/master/java/dataflow-connector-examples/src/main/java/com/google/cloud/bigtable/dataflow/example/HelloWorldWrite.java 然