Kafka Streams/如何获得一个iterator正在迭代的分区？
在我的Kafka Streams应用程序中，我有一个任务来设置一个预定的（按墙时间）标点符号。标点符号遍历商店的条目并对它们做一些事情。像这样：
var store = context().getStateStore("MyStore");
var iter = store.all();
while (iter.hasNext()) {
var entry = iter.next();
// ... do something with the entry
}
// Print a summary (now): N entries processed
// Print a summary (wish): N entries processed in partition P
由于我在这里使用单个存储（可能是分区的），我假设标点符号的每一次执行都绑定到该存储的单个分区。
有可能找出标点器在哪个分区上运行吗？用于ProcessorContext的java文档。partition（）声明此方法在标点符号中返回-1。
我读过《Kafka流：标点与过程》及其答案。我可以理解，一般来说，任务与特定分区无关。但是迭代器应该与IMO绑定。
我怎样才能找到分区呢？
或者我认为存储迭代器的某个特定实例与partion绑定是错误的吗？
我需要它的原因：我想在一些日志消息中包含分区号。现在，我有几个几乎相同的日志消息，说明标点器做这个和那个。为了使这些消息“唯一”，我想在其中包含分区号。
共有1个答案
只是在这里张贴https://issues.apache.org/jira/browse/KAFKA-12328提供的答案：
我只是使用了上下文。taskId（）。它在值的末尾，下划线之后包含分区号。这对我来说已经足够了。
-
主要内容：实例,查找最大与最小元素,实例,获取迭代器的长度,实例,Scala Iterator 常用方法Scala 集合 Scala Iterator（迭代器）不是一个集合，它是一种用于访问集合的方法。 迭代器 it 的两个基本操作是 next 和 hasNext。 调用 it.next() 会返回迭代器的下一个元素，并且更新迭代器的状态。 调用 it.hasNext() 用于检测集合中是否还有元素。 让迭代器 it 逐个返回所有元素最简单的方法是使用 while 循环： 实例 object T
-
Scala 集合 Scala Iterator（迭代器）不是一个集合，它是一种用于访问集合的方法。 迭代器 it 的两个基本操作是 next 和 hasNext。 调用 it.next() 会返回迭代器的下一个元素，并且更新迭代器的状态。 调用 it.hasNext() 用于检测集合中是否还有元素。 让迭代器 it 逐个返回所有元素最简单的方法是使用 while 循环： object Test
-
如果要从一个数据集中获取一个数据项，可以对这个数据集进行迭代。 JavaScript 提供了许多迭代集合的方法，从简单的 for 循环到 map() 和 filter()。本节要介绍的迭代器也是一种方案，并且迭代器将迭代的概念直接带入核心语言，同时提供了一种机制来自定义 for...of 循环的行为。 1. 慕课解释 迭代器是一种特殊对象，它符合迭代器协议规范。在 TypeScript 中，我们可
-
问题内容： 这是我下面的代码，我需要从中解析出单独的项目。这是我第一次使用JSON。因此，不确定如何解析以从中获取单个项。 我的JSON看起来像这样： 我需要，，，，，从上述目的。谁能提供任何建议如何有效地做到这一点？ 问题答案： 您可以尝试这样做，它将在json对象中递归地找到所有键值，并构造为map。您只需从Map中获取所需的键即可。 输出：
-
本文向大家介绍迭代器 Iterator 是什么？相关面试题，主要包含被问及迭代器 Iterator 是什么？时的应答技巧和注意事项，需要的朋友参考一下 terator 接口提供遍历任何 Collection 的接口。我们可以从一个 Collection 中使用迭代器方法来获取迭代器实例。迭代器取代了 Java 集合框架中的 Enumeration，迭代器允许调用者在迭代过程中移除元素。
-
Iterator模式是Java和.Net编程环境中非常常用的设计模式。 此模式用于获取以顺序方式访问集合对象的元素的方法，而无需了解其基础表示。 迭代器模式属于行为模式类别。 实现 (Implementation) 我们将创建一个Iterator导航方法的Iterator接口和一个重新构造迭代器的Container接口。 实现Container接口的具体类将负责实现Iterator接口并使用它 I