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

New consumer should not require the deprecated partition.assignment.strategy

    XMLWordPrintableJSON

Details

    Description

      The partition.assignment.strategy config is deprecated with the new consumer group protocol KIP-848. With the new protocol, server side assignors are supported for now, defined in the property
      group.remote.assignor, and with default values selected by the broker, so it's not even a required property.

      The new AsyncKafkaConsumer supports the new protocol only, but it currently throws an IllegalStateException if a call to subscribe is made and the deprecated config partition.assignment.strategy is empty (see throwIfNoAssignorsConfigured).
       
      We should remove the reference to ConsumerPartitionAssignor in the AsyncKafkaConsumer, along with it's validation for non-empty on subscribe (only use it has)

      Attachments

        Issue Links

          Activity

            People

              lianetm Lianet Magrans
              lianetm Lianet Magrans
              Lucas Brutschy Lucas Brutschy
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: