-
|
Howdy folks. I've run into an issue with the pause/poll/resume API that I haven't been able to address by reading the FAQ, nor by digging through the library's sources. Essentially, what happens is that I:
What I see is that that pausing seems to have no discernable (by me) impact on the polling, i.e. Is this expected behavior? The documentation for the
...which leads me to believe that it is not. My expectation is that after the pausing function is called and before the resumption function is called that the polling function will return no messages from the paused partition. I have noticed that if I sleep for, oh, 10 or so seconds before pausing the topic that things work as expected. My read of these logs tell me that the code that deals with Logs |
Beta Was this translation helpful? Give feedback.
Answered by
laser
Aug 27, 2022
Replies: 1 comment
-
|
OK, I figured it out, and will leave my answer here so that others might avoid asking the same dumb question that I just asked: One must wait to pause until one has an assignment, and there's an API that one can use to learn of their assignment (link). The 0026-consume_pause.c served as a useful guide. |
Beta Was this translation helpful? Give feedback.
0 replies
Answer selected by
laser
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
OK, I figured it out, and will leave my answer here so that others might avoid asking the same dumb question that I just asked:
One must wait to pause until one has an assignment, and there's an API that one can use to learn of their assignment (link). The 0026-consume_pause.c served as a useful guide.