Apache Nifi站点到站点数据分区
我在NiFi流中有一个输出端口，我有一个Flink作业，它使用NiFi站点到站点协议（Flink提供适当的连接器）从这个端口消耗数据。消耗是并行的--即有多个Flink源从同一个NiFi端口读取。
我想要实现的是运行中的Flink源之间的分区数据负载平衡--即确保具有相同密钥的数据始终被传递到相同的Flink源（类似于ActiveMQ消息组或Kafka分区）。这是订购需要的。
不幸的是，我找不到任何文件说明如何实现这一点。任何建议都很感谢。
先谢谢你,
共有1个答案
站点到站点并不是真的要做你所要求的。实现这一目标的最佳途径是NiFi向Kafaka出版，然后从Kafaka那里闪现消费。
-
1. 创建站点 一般情况下，您需要在百度统计中创建站点才能获取跟踪代码及查看网站数据。 具体创建步骤： 登录百度统计，选择“管理->网站列表”标签； 点击页面右上方“新增网站”按钮，弹出新建对话框： 输入网站域名，域名格式不正确，将无法创建。 可输入如下4种域名形式： 主域名（如：www.baidu.com） 二级域名（如：sub.baidu.com） 子目录（如：www.baidu.com/su
-
1. 创建站点 一般情况下，您需要在百度统计中创建站点才能获取跟踪代码及查看网站数据。 具体创建步骤： 登录百度统计，选择“管理->网站列表”标签； 点击页面右上方“新增网站”按钮，弹出新建对话框： 输入网站域名，域名格式不正确，将无法创建。 可输入如下4种域名形式： 主域名（如：www.baidu.com） 二级域名（如：sub.baidu.com） 子目录（如：www.baidu.com/su
-
1. 简介 全埋点功能会自动记录元素的点击，可支持回溯点击事件数据，使您不再有错埋、漏埋的担忧。除此以外，您可参考全埋点数据，找到具有监控价值的元素，深挖用户行为数据价值，辅助优化决策。 2. 如何开启全埋点 您可前往【管理-代码管理-埋点设置】对全埋点功能进行管理。强化版及以上的用户默认开通全埋点，推荐保持开通状态，以支持事件功能及相关点击数据的查看。 3. 如何查看全埋点数据 您可前往【事件分
-
问题内容： 我想提供一段Javascript代码，该代码可在包含Javascript的任何网站上运行，但是它始终需要在托管Javascript的服务器上获取更多数据（甚至修改数据）。我知道出于明显的原因有一些安全限制。 考虑xyz.com上托管的index.html，其中包含以下内容： some.js能够使用XMLHttpRequest将数据发布到abc.com吗？换句话说，因为我们从那里加载了J
-
configure脚本支持几种本地配置决策方式。它们是用户指明外部软件的位置，包括或除去可选的特征， 以修改过的名称安装的程序，以及为configure选项设置缺省值的手段。 与外部软件一起工作 有些软件包需要，或者可选地使用其它已经安装的软件包。用户可以把命令行选项传递给configure 以指明使用那个外部软件。选项采用下列形式之一：--with-package[=arg]--without-
-
Django 最强大的部分之一是自动生成的Admin 界面。它读取模型中的元数据来提供一个强大的、生产环境就绪的界面，使内容提供者能立即用它向站点中添加内容。在这篇文档中，我们讨论如何去激活、使用和自定义Django 的Admin 界面。 概述 通过使用startproject 创建的默认项目模版中，Admin 已启用。 下面的一些要求作为参考： 添加 'django.contrib.admin'