kafka protocol_error ai_generated true

org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support the group protocol version required by the consumer

ID: kafka/unsupported-version-join-group

Also available as: JSON · Markdown · 中文
88%Fix Rate
84%Confidence
1Evidence
2024-03-20First Seen

Version Compatibility

VersionStatusIntroducedDeprecatedNotes
3.0.0 active
3.3.0 active
3.6.0 active

Root Cause

Consumer requests a group protocol version (e.g., 2) that broker does not support due to version mismatch between consumer and broker.

generic

中文

消费者请求的组协议版本(例如2)代理不支持,原因是消费者和代理之间的版本不匹配。

Official Documentation

https://kafka.apache.org/documentation/#upgrade

Workarounds

  1. 85% success Set consumer's 'group.protocol' to 'classic' and ensure broker supports classic protocol (Kafka 3.0+).
    Set consumer's 'group.protocol' to 'classic' and ensure broker supports classic protocol (Kafka 3.0+).
  2. 95% success Upgrade broker to version that supports the consumer's group protocol (e.g., upgrade to 3.6 for consumer protocol v2).
    Upgrade broker to version that supports the consumer's group protocol (e.g., upgrade to 3.6 for consumer protocol v2).
  3. 90% success Downgrade consumer client library to match broker version (e.g., use kafka-clients 3.3.0 with broker 3.3.0).
    Downgrade consumer client library to match broker version (e.g., use kafka-clients 3.3.0 with broker 3.3.0).

中文步骤

  1. 将消费者的 'group.protocol' 设置为 'classic',并确保代理支持经典协议(Kafka 3.0+)。
  2. 升级代理到支持消费者组协议的版本(例如,升级到3.6以支持消费者协议v2)。
  3. 降级消费者客户端库以匹配代理版本(例如,使用kafka-clients 3.3.0与代理3.3.0)。

Dead Ends

Common approaches that don't work:

  1. 75% fail

    Classic protocol may not be supported by older brokers; error persists if broker version is too low.

  2. 90% fail

    Consumer version mismatch with broker causes unsupported version errors; both must be compatible.

  3. 80% fail

    Inter-broker protocol version affects broker communication, not consumer group protocol; does not fix consumer-side error.