This issue is to track the code behavior discussed in this comment #589 (comment).
In the kafka dispatcher, we unsubscribe and re-subscribe when dealing an existing subscription. This behavior was retained from the old kafka bus implementation. It is unclear as to why this was done. However, it is prudent to understand the rationale behind this from the original authors.
This issue is to track the code behavior discussed in this comment #589 (comment).
In the kafka dispatcher, we unsubscribe and re-subscribe when dealing an existing subscription. This behavior was retained from the old kafka bus implementation. It is unclear as to why this was done. However, it is prudent to understand the rationale behind this from the original authors.