Получение: org. apache .kafka.common.errors.TimeoutException: Истекло время ожидания назначения узла - PullRequest
Новая
       15

Получение: org. apache .kafka.common.errors.TimeoutException: Истекло время ожидания назначения узла

0 голосов
/ 07 мая 2020

Привет, я недавно изменил версию Kafka-client моего приложения с весенней загрузкой с 1.3.1-274 на 1.6.1-335, и внезапно я начинаю получать эти ошибки в своих тестах.

Это были изменения который я сделал в моем файле build.gradle :

До 

compile group: 'com.module.commons', name: 'kafka-client-java', version:'1.3.1-274'
compile group: 'com.module.commons', name: 'kafka-client-spring', version:'1.1.17-45'

После 

compile group: 'com.module.commons', name: 'kafka-client-java', version:'1.6.1-335'
compile group: 'com.module.commons', name: 'kafka-client-spring', version:'1.6.1-51'

Это была серия ошибок, которые я получил после изменения версии: 

 java.lang.IllegalStateException: Failed to load ApplicationContext

    Caused by:
    org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'com.swiggy.kafka.client.springlistener.KafkaTemplateListener': Invocation of init method failed; nested exception is org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

        Caused by:
        org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

            Caused by:
            java.lang.RuntimeException: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

                Caused by:
                java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

                    Caused by:
                    org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

Кто-нибудь может предложить возможную причину того же.

...