Currently, only the producer is aware of canary events in its source streams and skips them. However, also the update stream has canary events enabled (by default)
Canary events are necessary to prevent losing the committed/consumed kafka topic offsets, see comment.
AC
- consumer skips canary events