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
Uh oh!
There was an error while loading. Please reload this page.
-
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