假设我们有两个流任务(在不同的实例上运行(。源主题有1个分区。应用程序启动后，分区-1被分配给流任务-1。现在，Stream-1任务开始进行一些处理和转换，耗时超过10分钟。Kafka框架是否有可能触发重新平衡，并将Stream-Task-1从系统中取出，并将P1分配给Stream-Task-2？？
流任务是否有一些属性，以控制再平衡不应触发红色的时间！！
谢谢各位的回复。
我认为Stream Task只是指Streams应用程序的不同实例？A"；StreamTask"；是Streams用来定义工作单元的内部术语。如果您只有一个输入主题和一个分区，那么您的应用程序中就有一个StreamTask。
如果您的一个实例未能在轮询间隔内进行轮询，那么是的，它将被踢出组，其任务(即分区(将交给另一个实例。如果您认为它可能会在处理中停滞10分钟，那么您应该相应地调整max.poll.interval.ms配置。