Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

KAFKA-14500; [2/N] Rewrite GroupMetadata in Java #13663

Merged
merged 15 commits into from
May 12, 2023
Merged

KAFKA-14500; [2/N] Rewrite GroupMetadata in Java #13663

Changes from 1 commit
Commits
Show all changes
15 commits
Select commit Hold shift + click to select a range
d7113b5
rewrite GroupMetadata
jeffkbkim May 2, 2023
fc0b7b4
fix
jeffkbkim May 2, 2023
6b15b2d
javadocs
jeffkbkim May 5, 2023
ca3db3e
add unit test
jeffkbkim May 6, 2023
aabc26e
remove offset classes
jeffkbkim May 8, 2023
a0351b3
don't handle exception in future completion
jeffkbkim May 8, 2023
8f1ce91
rebase on trunk
jeffkbkim May 9, 2023
dd24c78
undo
jeffkbkim May 9, 2023
785cc11
checkstyle
jeffkbkim May 9, 2023
e5bd48e
address comments
jeffkbkim May 10, 2023
461f785
add group id getter
jeffkbkim May 10, 2023
6cde9b3
add protocol type getter
jeffkbkim May 10, 2023
6f65670
address comments
jeffkbkim May 11, 2023
1238530
address comments
jeffkbkim May 11, 2023
c47b4a6
address comments
jeffkbkim May 11, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
add protocol type getter
  • Loading branch information
@jeffkbkim
jeffkbkim committed May 10, 2023
commit 6cde9b357d70aaacd52ce771800b39a7b1047a03
7 changes: 7 additions & 0 deletions group-coordinator/src/main/java/org/apache/kafka/coordinator/group/generic/GenericGroup.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -205,6 +205,13 @@ public Optional<String> protocolName() {
return this.protocolName;
}

/**
* @return the protocol type.
*/
public Optional<String> protocolType() {
return this.protocolType;
}

/**
* @return the current group state.
*/
Expand Down