Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9882

Add Block getAssignments()

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • Critical
    • Resolution: Unresolved
    • 2.5.0
    • None
    • clients
    • None

    Description

      In 2.0, the KafkaConsumer poll(long) was deprecated and replaced with a poll(Duration). The poll(Duration) does not block for consumer assignments.

      Now, there isn't a blocking method that can get consumer assignments.

      A new KafkaConsumer method needs to be added that blocks while getting consumer assignments.

      The current workaround is to poll for a short amount of time in a while loop and check the size of assignment(). This isn't a great method of verifying the consumer assignment.

      Attachments

        Activity

          People

            Unassigned Unassigned
            eljefe6aa Jesse Anderson
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: