Kafka流-任务/分区/处理器关系
Kafka流-任务/分区/处理器关系
提问于 2018-06-13 14:24:55
我正在使用低级别的API处理器.我有一个有6个分区的主题。在实现Processor<K,V>的类中，我定义了一些类变量(非静态)。据我所知，将有6项任务。当我们启动流应用程序时，我看到有6个对象正在实例化实现Processor<K,V>的类。我们能将这些对象实例与任务关联起来吗？在重新平衡期间，我假设分区可以在单独的线程上切换到另一个任务，也可以切换到另一个实例。如果是这样的话，会不会实例化一个新对象，该类为在不同线程或实例上重新分配的分区实现Processor<K,V>，并在与该分区对应的现有对象上调用close方法？
回答 1
Stack Overflow用户
回答已采纳
发布于 2018-06-13 20:58:16
如果任务从一个线程移动到另一个线程，则该任务将被关闭，并将创建一个包含新处理器对象的新任务。
因此，通过设计，所有局部变量都是短暂的。
如果需要在再平衡之间保持任何状态，则需要将存储附加到Processor。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/50839679
复制相关文章
相似问题
腾讯云开发者
