Kafka Streams：“协调器选择无效分配协议：空”的情况

Question

我在 Kafka Streams 应用程序（2.1 版）的日志中发现了这个问题。

 Coordinator selected invalid assignment protocol: null

Kafka 客户端库中的代码看起来很简单，其中没有找到分配器：

PartitionAssignor assignor = lookupAssignor(assignmentStrategy);
    if (assignor == null)
        throw new IllegalStateException("Coordinator selected invalid 
assignment protocol: " + assignmentStrategy);

而 lookupAssignor 只是按名称查找：

private PartitionAssignor lookupAssignor(String name) {
    for (PartitionAssignor assignor : this.assignors) {
        if (assignor.name().equals(name))
            return assignor;
    }
    return null;
}

在什么情况下这可能发生在 Kafka Streams 应用程序上？后果是什么？