Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1326 New consumer checklist
  3. KAFKA-1330

Implement subscribe(TopicPartition...partitions) and pool(timeout) in the consumer

          Details

          • Type: Sub-task
          • Status: Resolved
          • Priority: Major
          • Resolution: Duplicate
          • Affects Version/s: None
          • Fix Version/s: 0.9.0.0
          • Component/s: consumer
          • Labels:
            None

            Description

            This involves adding basic fetch functionality (equivalent to SimpleConsumer) to the new consumer. Effectively:

            1) Implement subscribe(TopicPartition...partitions) and unsubscribe(TopicPartition...partitions).
            2) Implement pool(timeout).
            3) Add memory management to the consumer.

              Attachments

              1. KAFKA-1330_2014-07-21_16:44:23.patch
                162 kB
                Jay Kreps
              2. KAFKA-1330.patch
                177 kB
                Jay Kreps

                Issue Links

                blocks

                Sub-task - The sub-task of the issue KAFKA-1331 Add ability to commit offsets to the new consumer

                • Major - Major loss of function.
                • Resolved
                duplicates

                Sub-task - The sub-task of the issue KAFKA-1760 Implement new consumer client

                • Major - Major loss of function.
                • Resolved

                  Activity

                    People

                    • Assignee:
                      jkreps Jay Kreps
                      Reporter:
                      nehanarkhede Neha Narkhede
                    • Votes:
                      0 Vote for this issue
                      Watchers:
                      3 Start watching this issue

                      Dates

                      • Created:
                        Updated:
                        Resolved: