Page History

...

• Change KafkaConsumer to internally select Consumer as the default rebalance protocol if no group.protocol config is defined.  
• Deprecate support for the Classic protocol in the KafkaConsumer
  • deprecate group.protocol  config in the public API ConsumerConfig  
  • deprecate classic protocol configs in the public API ConsumerConfig : partition.assigment.strategy, session.timeout.ms, heartbeat.interval.ms (these properties already fail with ConfigException if used with the Consumer protocol) 

  • deprecate KafkaConsumer#enforceRebalance methods
    

  • deprecate KafkaConsumer#subscribe methods that takejava.util.regex.Pattern. Suggest upgrading to KafkaConsumer#subscribe equivalents that take org.apache.kafka.clients.consumer.SubscriptionPattern
  • deprecate the org.apache.kafka.clients.consumer.ConsumerPartitionAssignor  interface
• if group.protocol explicitly set to classic: log warning about using a deprecated protocol that will be removed in the next major release. Suggest removing the property (upgrade to the default Consumer protocol)
• The “classic” protocol remains supported in this phase (showing deprecation log). 
• All usages of the KafkaConsumer within the code base following the default behaviour will be migrated to use using the Consumer protocol, e.g. Connect usages of KafkaConsumer will use the new protocol.
• Target: Apache Kafka 5.0

...