отправьте подтверждение kafka в компоненте camel-kafka

Question

Я новичок в компоненте camel-kafka. У меня есть все настройки для отправки и получения сообщений с сервера kafka с использованием компонента camel-kafka. Я использую подобный код, как указано ниже:

from("kafka:localhost:9092?topic=test&groupId=testing&autoOffsetReset=earliest&consumersCount=1") 
         .process(new Processor() { 
          @Override 
          public void process(Exchange exchange) 
            throws Exception { 
           String messageKey = ""; 
           if (exchange.getIn() != null) { 
            Message message = exchange.getIn(); 
            Integer partitionId = (Integer) message 
              .getHeader(KafkaConstants.PARTITION); 
            String topicName = (String) message 
              .getHeader(KafkaConstants.TOPIC); 
            if (message.getHeader(KafkaConstants.KEY) != null) 
             messageKey = (String) message 
               .getHeader(KafkaConstants.KEY); 
            Object data = message.getBody(); 


            System.out.println("topicName :: " 
              + topicName + " partitionId :: " 
              + partitionId + " messageKey :: " 
              + messageKey + " message :: " 
              + data + "\n"); 
    /// I perform many other operations here like persist the object in DB etc. 
           } 
          } 
         }); 

Здесь проблема в том, что я не отправка любой подтверждени Кафке он получает такое же сообщение трижды с сервера. Мой вопрос в том, как я могу отправить подтверждение на kafka вручную? Я не нашел надлежащей документации в компоненте camel-kafka.

Answer 1

Вам не нужно отправлять подтверждение обратно в kafka. Вы не указали разрешение автообмена, значение по умолчанию которого равно true, что означает, что для автоматической фиксации установлено значение true. Это касается подтверждения.

Уточнить, какая версия kafka использует компонент camel-kafka? Ваша настройка верблюда-кафки в порядке. Вы можете получать повторяющиеся сообщения из-за версии kafka, которую используете.