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.

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

Merged consumer group support #390

Merged
merged 52 commits into from
Sep 4, 2023
Merged

Merged consumer group support #390

merged 52 commits into from
Sep 4, 2023

Conversation

akrambek
Copy link
Contributor

@akrambek akrambek commented Sep 1, 2023

Description

Please include a summary of the changes and the related issue. Please also include relevant motivation and context. List any dependencies that are required for this change.

Fixes # (issue)

@akrambek akrambek marked this pull request as ready for review September 4, 2023 07:10
@@ -57,6 +58,8 @@ read "Hello, world #A5"
write advise zilla:flush ${kafka:flushEx()
.typeId(zilla:id("kafka"))
.merged()
.typeId(1)
Copy link
Contributor

Choose a reason for hiding this comment

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

Can this be removed?

@@ -43,6 +43,8 @@ connected
write advise zilla:flush ${kafka:flushEx()
.typeId(zilla:id("kafka"))
.merged()
.typeId(1)
Copy link
Contributor

Choose a reason for hiding this comment

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

Can this be removed?

@@ -2493,49 +3396,65 @@ private void doEncodeSyncGroupRequest(
final int encodeOffset = DataFW.FIELD_OFFSET_PAYLOAD;
final int encodeLimit = encodeBuffer.capacity();

int encodeProgress = encodeOffset;
AtomicInteger encodeProgress = new AtomicInteger(encodeOffset);
Copy link
Contributor

Choose a reason for hiding this comment

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

Please use MutableInteger instead if necessary.

public int routedTypeId()
{
return BindingHandler.super.routedTypeId();
}
Copy link
Contributor

Choose a reason for hiding this comment

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

Can this be removed?

jfallows
jfallows previously approved these changes Sep 4, 2023
@jfallows jfallows merged commit e3c08f2 into aklivity:develop Sep 4, 2023
jfallows pushed a commit that referenced this pull request Sep 5, 2023
* Merged consumer group support (#390)

* Adapt to consumer group changes

* Change write notify to read

* Send init empty data to trigger syncgroup

* Add new test

---------

Co-authored-by: Akram  Yakubov <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants