Потоки Кафки: случаи, когда «координатор выбрал неверный протокол назначения: ноль» - PullRequest
Новая
       12

Потоки Кафки: случаи, когда «координатор выбрал неверный протокол назначения: ноль»

1 голос
/ 20 марта 2019

Я нахожу эту проблему в журналах приложения 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? Каковы последствия?

...