Apache Nifi ConsumeKafka_1_0处理器究竟是如何工作的
我有尼菲集群和Kafka也安装在那里。
创建了一个包含5个分区的主题，开始使用一个Gup-id使用该主题。以便每个分区都将获得唯一的消息。
现在我创建了5个ConsumeKafka_1_0处理器，目的是在每个消费者端获得唯一的消息。但是只有2个ConsumeKafka_1_0正在消费所有的消息，其余的设置是理想的。
现在我所做的是启动5命令行Kafka消费者，发生的事情是，我能够看到所有分区都在获取消息，并且只能以循环方式从命令行消费者使用它们。
此外，我尝试描述Kafka组，我看到的是只有2个Nifi ConsumeKafka_1_0正在消耗所有5个分区，其余的是理想的，见快照。
你能不能让我知道我在这里用Nifi消费者处理器做错了什么。
注意——我用的Nifi版本是1.5，Kafka版本是1.0。
共有1个答案
我写了这篇文章来解释与Kafka的集成是如何工作的：
https://bryanbende . com/development/2016/09/15/Apache-nifi-and-Apache-Kafka
Apache Kafka客户端（由NiFi使用）是将分区分配给消费者的客户端。
通常，如果您有一个5节点NiFi集群，画布上有1个ConsumeKafka处理器和1个并发任务，那么每个节点将消耗1个分区。
-
我一直在弄清楚口译员的确切工作方式，在谷歌上搜索了一下，得出了一些结论，只是希望有人能纠正一下，让我更好地了解口译员的工作。 所以我的理解是： 解释器是一种将代码从高级语言转换为机器格式的软件程序 现在我仍然不清楚中间发生的子过程，即。 解释器产生中间代码 然后优化解释的代码 然后生成目标代码 并最终执行 还有一些问题： 那么解释器是否单独负责生成目标代码？并执行它？ 执行是否意味着它在JVM或底
-
问题内容： 我无法确切地理解反射模式如何处理我的数组。我 有一个非常简单的数组： [[ 1. 1. 1. 1. 1.] [ 2. 2. 2. 2. 2.] [ 4. 4. 4. 4. 4.] [ 5. 5. 5. 5. 5.]] Applying a uniform (mean) filter with a window size of 3 I get the following: [[ 1.33
-
我写了下面的测试代码在Java使用ReentantReadWriteLock来了解公平和不公平模式之间的区别。然而，我看到在两种模式下，结果和输出总是相同的。它似乎总是在公平模式下工作。谁能解释一下，在何种情况下，公平和不公平模式会导致不同的行为？ 输出总是： 当我将锁创建更改为公平模式时，上面的输出是我期望看到的： 对于非公平模式，我希望看到以下输出：
-
因此，Dart API对＝＝运算符这样说： 相等运算符。 所有对象的默认行为是，当且仅当此对象和其他对象是同一对象时，才返回true。 重写此方法以在类上指定不同的相等关系。重写方法仍然必须是等价关系。也就是说，它必须是： Total:它必须为所有参数返回一个布尔值。它不应该扔。 反身：对于所有对象 必须为。 对称:对于所有对象< code>o1和< code > O2 ,< code > O1
-
内部构造函数的准确定义是什么？在Julia-V0.6+中，“任何可以使用签名（注意部分）调用的构造函数都是内部构造函数”是正确的吗？ 正如下面的注释中所讨论的，仅限于外部的构造函数实际上是吗？ 使用检查方法是否是内部/外部构造函数是否正确？ Julia自动定义的默认构造函数与用户显式定义的相应构造函数有什么不同？ 顺便说一句，我知道如何使用以及何时使用内部构造函数。我知道什么是内部构造函数，直到只
-
问题内容： HashMap中的Hash Collision或Hashing Collision并不是一个新话题，我遇到了多个博客和讨论区，解释了如何产生Hash Collision或如何以模棱两可和详细的方式避免它。我最近在一次采访中遇到了这个问题。我有很多事情要解释，但我认为准确地给出正确的解释真的很困难。抱歉，如果我在这里重复我的问题，请给我准确的答案： 哈希冲突到底是什么？它是一项功能或常见
-
上周我阅读了有关vertx的文档。我不明白的是vertx处理器是如何工作的？例如 和服务器是： （P.S.我知道我首先应该检查处理程序是否成功，然后采取一些措施，但为了简化代码，我删除了这种检查，如果在30秒内没有任何响应，则处理程序中会出现异常，也会从正式文档中删除。） 从上面的代码中，客户端每秒发送请求，并且不等待响应，但是它有一个处理程序，当响应到来时将执行该处理程序。 jdbcVertx监
-
据我所知，我已经阅读了很多关于HTTP方法差异和确切优势的资源，这似乎是一份更好地理解和使用RESTAPI的合同。我的困惑如下： 我有一个表格： 我有一张这样的桌子： 在控制器中，我更新了我们发送的所有请求字段。 所有的PUT、PATCH和POST方法都以相同的方式工作<如果PUT应该完全重新生成资源，则它不会将input3更改为NULL。补丁更改了input1和input2。POST的工作原理也