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

http-kafka will fetch messages that have been deleted by a retention policy #897

Closed
vordimous opened this issue Apr 4, 2024 · 0 comments · Fixed by #1033
Closed

http-kafka will fetch messages that have been deleted by a retention policy #897

vordimous opened this issue Apr 4, 2024 · 0 comments · Fixed by #1033
Assignees
Labels
bug Something isn't working

Comments

@vordimous
Copy link
Contributor

Describe the bug
Zilla is returning messages in a GET request using http-kafka binding fetch that have been deleted from the topic via a retention policy.

To Reproduce
Steps to reproduce the behavior:

  1. use any http-kafka fetch config (bug was confirmed using the quickstart and taxi-demo)
  2. configure the topic with --config cleanup.policy=compact,delete --config delete.retention.ms=6000 --config retention.ms=6000
  3. produce messages to the topic
  4. wait for messages to be deleted
  5. See all messages in the GET response, but response should not have deleted messages
  6. restart Zilla
  7. GET response now shows the correct data

Expected behavior
Zilla doesn't return delete messages.

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 a pull request may close this issue.

2 participants