I want to read messages from Kafka topic (wrapping my message processor with consumes
decorator of fastkafka
library).
But I want not just to auto-commit messages, but to commit them manually -- and only if the message processing was correct (when my extra function that was processing their internal data did not throw any exception).
How can it be done? How can I commit messages manually -- and only when I really want to commit them?
from FasfKafka library: how to commit messages in consumer manually when enable_autocommit=False?
No comments:
Post a Comment