Kafka Streams：标点符号与流程

Question

在流应用程序中的单个任务中，以下两个方法是否独立运行（意味着当方法“process”处理来自上游源的传入消息时，方法“punctuate”也可以基于指定 schedule 和 WALL_CLOCK_TIME 作为 PunctuationType？）或者它们是否共享同一个线程，因此它要么是在给定时间运行的线程，如果是这样，如果 process 方法不断从上游源获取消息，那么 punctuate 方法永远不会被调用？

• Processor.process（K 键，V 值）
  使用给定的键和值处理记录。

• ProcessorContext.schedule（长间隔，PunctuationType 类型，Punctuator 回调）
  为处理器安排定期操作。

另外，请澄清在标点法中分区 id 值为 -1 是什么意思。标点方法不是特定于任何分区吗？

• int ProcessorContext.partition()
  返回当前输入记录的分区id；如果它不可用（例如，如果从标点调用调用此方法），则可能为 -1

Answer 1

这两种方法都在一个线程中执行。如果有输入数据，基于挂钟的punctuate() 将被独立调用：在调用process() 之间，线程检查系统时间并在必要时调用punctuate()。

对于分区信息：是的，标点符号与分区无关。当然，标点符号是特定于任务的，但是，一个任务可能有多个输入分区（例如，如果它执行merge 或join），因此不清楚要传递哪些分区信息。为简单起见，单个分区大小写的处理方式与多分区大小写相同，标点符号与分区分离。