milvus/pkg/mq
yihao.dai aef7664fc6
fix: Prevent dispatcher merging if curTs is 0 (#34562)
When the main dispatcher has not yet consumed data, curTs is 0. During
this time, merging dispatchers should not be allowed; otherwise, the
data of the solo dispatcher will be skipped.

issue: https://github.com/milvus-io/milvus/issues/34255

---------

Signed-off-by: bigsheeper <yihao.dai@zilliz.com>
2024-07-11 00:02:50 +08:00
..
common enhance: move rocksmq from internal to pkg module (#33881) 2024-06-25 21:18:15 +08:00
mqimpl/rocksmq enhance: improve check health (#33800) 2024-07-01 10:16:06 +08:00
msgdispatcher fix: Prevent dispatcher merging if curTs is 0 (#34562) 2024-07-11 00:02:50 +08:00
msgstream enhance: add the tick log for the tt msgstream seek method (#34397) 2024-07-04 10:18:09 +08:00