Skip to content

Mqtt-kakfa will message bugfixes#644

Merged
jfallows merged 2 commits into
aklivity:developfrom
bmaidics:mqtt_kafka_bugs
Dec 18, 2023
Merged

Mqtt-kakfa will message bugfixes#644
jfallows merged 2 commits into
aklivity:developfrom
bmaidics:mqtt_kafka_bugs

Conversation

@bmaidics

Copy link
Copy Markdown
Contributor

No description provided.

@bmaidics bmaidics added the bug Something isn't working label Dec 14, 2023
@bmaidics bmaidics self-assigned this Dec 14, 2023
else
{
unAckedPackets--;
}

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

What does "unacked packet" mean in this context?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

We can't close the retained stream until we received back ALL the acks for any qos1/2 messages. So basically this is just a counter to know when every delivered message were acked.

@jfallows jfallows merged commit 6033778 into aklivity:develop Dec 18, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

bug Something isn't working

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants