Ручка KafkaRebalancer с пружинными конфигурациями

Question

Мы используем spring-kafka (1.3.2.RELEASE) в нашем приложении.Прямо сейчас мы используем auto-commit = true в наших конфигурациях.Мы столкнулись с некоторой проблемой из-за одного и того же, например, одного и того же смещения, получаемого при считывании несколько раз, поэтому теперь мы планируем выполнить ручные коммиты и, возможно, сохранить смещения чтения в некотором внешнем репозитории.,Я прочитал документацию, в простой Java, слушатель перебалансировки настроен с использованием ContainerProperties.setConsumerRebalanceListener (rebalanceListner);

https://docs.spring.io/spring-kafka/reference/htmlsingle/#_very_very_quick

Я ищу для настройки списков ребалансировки с использованием конфигураций Spring Java, но не могу найти их.Пожалуйста, дайте мне знать.

Спасибо

Answer 1

Если я вас правильно понимаю, вы хотите иметь что-то вроде этого:

@Bean
ContainerProperties containerProperties() {
   ContainerProperties containerProperties = new ContainerProperties(SOME_TOPIC);
   containerProperties.setConsumerRebalanceListener(myConsumerRebalanceListener());
   // Other properties set
   return containerProperties;
}

@Bean
ConsumerRebalanceListener myConsumerRebalanceListener() {
   return new ConsumerRebalanceListener() {

            @Override
            public void onPartitionsRevoked(Collection<TopicPartition> partitions) {

            }

            @Override
            public void onPartitionsAssigned(Collection<TopicPartition> partitions) {

            }
   }
}

Этот бин containerProperties вы можете использовать в экземпляре KafkaMessageListenerContainer или вы можете заполнить этот myConsumerRebalanceListener вAbstractKafkaListenerContainerFactory.getContainerProperties().