ProcessorContext.schedule 是线程安全的吗？
Is ProcessorContext.schedule thread-safe?
我想知道 ProcessorContext.schedule 是否是线程安全的，以便我可以生成新线程来执行 Punctuator 回调？
另外，如果消费者只消费 1 个分区，但我们设置 num.stream.threads=2。这会自动为调度程序生成一个新线程吗？
经过一番尝试，我发现答案可能是"no"。
那么为调度程序线程安全生成新线程的推荐方法是什么？
注册一个标点不会产生一个新线程。使用的线程数仅由 num.stream.threads 配置决定。因此，如果您注册一个标点符号，它将在与拓扑相同的线程上执行，因此它是线程安全的。
如果您配置的线程多于可用的输入主题分区，一些线程将不会分配任何工作，因此它们不会执行任何标点符号。
我想知道 ProcessorContext.schedule 是否是线程安全的，以便我可以生成新线程来执行 Punctuator 回调？
另外，如果消费者只消费 1 个分区，但我们设置 num.stream.threads=2。这会自动为调度程序生成一个新线程吗？
经过一番尝试，我发现答案可能是"no"。 那么为调度程序线程安全生成新线程的推荐方法是什么？
注册一个标点不会产生一个新线程。使用的线程数仅由 num.stream.threads 配置决定。因此，如果您注册一个标点符号，它将在与拓扑相同的线程上执行，因此它是线程安全的。
如果您配置的线程多于可用的输入主题分区，一些线程将不会分配任何工作，因此它们不会执行任何标点符号。