79134358

Date: 2024-10-28 16:51:20
Score: 2
Natty:
Report link

Its possible the consuming from Kafka itself is the problem here. I'd suggest checking the following, to try and diagnose the issue.

  1. Are you seeing any messages downstream of the windowing function, if you simply add a DoFn to log them out?

  2. If you remove the windowing function entirely, do you see messages, and does the problem go away?

This will isolate whether the issue is in consuming from Kafka, or in your windowing configuration

Reasons:
  • No code block (0.5):
  • Contains question mark (0.5):
  • Low reputation (1):
Posted by: John Casey