у нас есть один потребитель, который потребляет данные из кафки с 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 );
}
}