Потребитель не может быть настроен для автоматической фиксации для ackMode MANUAL_IMMEDIATE - PullRequest
Новая
       2

Потребитель не может быть настроен для автоматической фиксации для ackMode MANUAL_IMMEDIATE

0 голосов
/ 05 апреля 2019

Я пытаюсь вручную установить кафку, но безуспешно.

Потребитель не может быть настроен для автоматической фиксации для ackMode MANUAL_IMMEDIATE

потребительская конфигурация: 

     @Bean
      public Map<String, Object> consumerConfigs() {
        Map<String, Object> props = new HashMap<>();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFI bootstrapServers);
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFStringDeserializer.class);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIStringDeserializer.class
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "helloworld");
        /*
        Disabling the auto-commit feature.
        */
        props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false);

        return props;
      }

пример слушателя: 

@KafkaListener(topics = "${spring.kafka.topic}", groupId="helloworld", containerFactory = "kafkaListenerContainerFactory")
    private void listen(@Payload String payload, Acknowledgment acknowledgment) {

        acknowledgement.acknowledge(); 


  @Bean
  public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory =
        new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATE);

    return factory;
  }

это не совсем то же самое с моим, но похоже

2.2.5. ВЫПУСТИТЕ какие-нибудь идеи?

...