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:
- use any
http-kafka fetch config (bug was confirmed using the quickstart and taxi-demo)
- configure the topic with
--config cleanup.policy=compact,delete --config delete.retention.ms=6000 --config retention.ms=6000
- produce messages to the topic
- wait for messages to be deleted
- See all messages in the GET response, but response should not have deleted messages
- restart Zilla
- GET response now shows the correct data
Expected behavior
Zilla doesn't return delete messages.