Is there a way for the consumer to not consume from the beginning? #1525
Unanswered
Bobbins228
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I have a consumer that I want to consume only new messages but it is consuming old messages too.
For example I have two files file1.py and file2.py.
In file1 I have a prompt for the user to enter a message. When the message is inputted it is produced to "Topic A".
In file2 I have a consumer subscribed to "Topic A" and when it receives the message it does a calculation and produces a new message to "Topic B"
Back in file1 There is a consumer subscribed to "Topic B" and it prints the new message to the terminal.
This works as expected on the first run of the two files but after that I can run file2.py by itself and it will consume the message from the previously ran file1.py despite there being no message input this time.
I am just wondering if there is a field I can add when running the consumer that makes it look out for new messages rather than all messages. Thanks
Beta Was this translation helpful? Give feedback.
All reactions