Кафка с 5 разделами и одним потребителем получает сообщения только с одного раздела - PullRequest
0 голосов
/ 03 января 2019

у нас есть один потребитель, который потребляет данные из кафки с 5 разделами.у потребителя есть 5 groupid.

мы заметили, что каждый groupid потребляет сообщения только из одного раздела.в коде мы подписываемся на тему с помощью consumer.subscribe.

как мы понимаем с одним потребителем, каждый groupid должен получать сообщения со всех разделов.

не правы ли мы в нашем предположении?если нет то что вызывает проблему?

private void subscribe() {
        consumer.subscribe( Collections.singletonList( topic ) );
    } catch ( IllegalArgumentException  e ){
        LOG.error( "Kafka Failed to subscribe to kafka client ", e );
        e.printStackTrace();
    } catch( IllegalStateException e ){
        LOG.error( "Kafka Failed to subscribe to kafka client ", e );
        e.printStackTrace();
    } catch ( Exception e ){
        LOG.error( "Kafka Failed to subscribe to kafka client, topic: " + topic , e );
    }

}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...