Skip to content

KAFKA-17337: ConsumerConfig should default to CONSUMER for group.protocol#17107

Closed
kirktrue wants to merge 19 commits intoapache:trunkfrom
kirktrue:KAFKA-17337-default-to-CONSUMER-group-protocol
Closed

KAFKA-17337: ConsumerConfig should default to CONSUMER for group.protocol#17107
kirktrue wants to merge 19 commits intoapache:trunkfrom
kirktrue:KAFKA-17337-default-to-CONSUMER-group-protocol

Conversation

@kirktrue
Copy link
Copy Markdown
Contributor

@kirktrue kirktrue commented Sep 5, 2024

Updated DEFAULT_GROUP_PROTOCOL to use CONSUMER instead of CLASSIC, updated GROUP_PROTOCOL_DOC to be a little more flexible going forward, and cleaned up unit tests that assumed CLASSIC as the default group protocol.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

…ocol

Updated DEFAULT_GROUP_PROTOCOL to use CONSUMER instead of CLASSIC, updated GROUP_PROTOCOL_DOC to be a little more flexible going forward, and cleaned up unit tests that assumed CLASSIC as the default.
@kirktrue kirktrue added consumer KIP-848 The Next Generation of the Consumer Rebalance Protocol labels Sep 5, 2024
@kirktrue
Copy link
Copy Markdown
Contributor Author

kirktrue commented Sep 5, 2024

I would like to run the system tests with this change before review.

Copy link
Copy Markdown
Member

@AndrewJSchofield AndrewJSchofield left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

For some reason, listing all the GroupProtocol options dynamically led to a StackOverflowError. Changed it to list the protocols explicitly to avoid this.

The system is out of resources.
Consult the following stack trace for details.
java.lang.StackOverflowError
        at com.sun.tools.javac.comp.Attr.visitLambda(Attr.java:2296)
        at com.sun.tools.javac.tree.JCTree$JCLambda.accept(JCTree.java:1624)
        at com.sun.tools.javac.comp.Attr.attribTree(Attr.java:576)
        at com.sun.tools.javac.comp.Attr.visitLambda(Attr.java:2435)
        at com.sun.tools.javac.tree.JCTree$JCLambda.accept(JCTree.java:1624)
        at com.sun.tools.javac.comp.Attr.attribTree(Attr.java:576)
        at com.sun.tools.javac.comp.Attr.visitLambda(Attr.java:2435)
        at com.sun.tools.javac.tree.JCTree$JCLambda.accept(JCTree.java:1624)
        at com.sun.tools.javac.comp.Attr.attribTree(Attr.java:576)
        at com.sun.tools.javac.comp.Attr.visitLambda(Attr.java:2435)
        at com.sun.tools.javac.tree.JCTree$JCLambda.accept(JCTree.java:1624)
@github-actions github-actions Bot added the core Kafka Broker label Oct 3, 2024
@kirktrue kirktrue closed this Jan 10, 2025
@kirktrue kirktrue deleted the KAFKA-17337-default-to-CONSUMER-group-protocol branch February 13, 2025 22:14
@kirktrue kirktrue restored the KAFKA-17337-default-to-CONSUMER-group-protocol branch February 13, 2025 22:14
@kirktrue kirktrue deleted the KAFKA-17337-default-to-CONSUMER-group-protocol branch February 13, 2025 22:14
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ci-approved clients consumer core Kafka Broker KIP-848 The Next Generation of the Consumer Rebalance Protocol small Small PRs

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants