Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14246 Update threading model for Consumer
  3. KAFKA-15508

Method always return the same value ApplicationEventProcessor.java

    XMLWordPrintableJSON

Details

    Description

      I'm not sure but i think that this is a bug, because method 'process' in ApplicationEventProcessor.java always return true:

          private boolean process(final PollApplicationEvent event) {
              Optional<RequestManager> commitRequestManger = registry.get(RequestManager.Type.COMMIT);
              if (!commitRequestManger.isPresent()) {
                  return true;
              }

              CommitRequestManager manager = (CommitRequestManager) commitRequestManger.get();
              manager.updateAutoCommitTimer(event.pollTimeMs);
              return true;
          }

      Attachments

        Issue Links

          Activity

            People

              kirktrue Kirk True
              rykovsi Svyatoslav
              Jun Rao Jun Rao
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: