Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
3.7.0
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
- duplicates
-
KAFKA-16255 AsyncKafkaConsumer should not use partition.assignment.strategy
- Resolved
- links to