apache-kafka - 有没有办法以编程方式在源任务中触发 Kafka 连接器重新平衡

Question

是否可以从源任务中触发 Kafka 连接器重新平衡。该任务可以检测到一些可能保证连接器重新平衡的异常情况。SourceTaskContext 没有像 SourceConnectorContext 所拥有的 requestTaskReconfiguration 这样的重新平衡方法。

我需要在任务而不是连接器中触发重新平衡。