subscription consumes eventlogs are blocked

[wenfengwang]

Bug Report

Please answer these questions before submitting your issue. Thanks!

1. Minimal reproduce step (Required)

1. run Vanus cluster with docker compose

cd deploy/docker-compose
docker compose up

2. create eventbus and subscription

vsctl eventbus create eventbus --name "regression_pubsub" --eventlog "4"

vsctl subscription create --name "regression_pubsub" \
  --eventbus "regression_pubsub" \
  --sink "host.docker.internal:18080" \
  --protocol "grpc"

3. run test/regression/pubsub

EVENTBUS=regression_pubsub VANUS_GATEWAY=[127.0.0.1:8080](http://127.0.0.1:8080/) go run test/regression/pubsub/main.go

2. What did you expect to see? (Required)

+-----+------------------+-------------------+---------+-------------------+----------------------------+-------------+----------+----------------+--------+---------------------------------+--------+-------------+---------------------------+---------------------------+
| NO. |        ID        |        NAME       | DISABLE |      EVENTBUS     |            SINK            | DESCRIPTION | PROTOCOL | SINKCREDENTIAL | CONFIG |             OFFSETS             | FILTER | TRANSFORMER |         CREATED_AT        |         UPDATED_AT        |
+-----+------------------+-------------------+---------+-------------------+----------------------------+-------------+----------+----------------+--------+---------------------------------+--------+-------------+---------------------------+---------------------------+
|     |                  |                   |         |                   |                            |             |          |                |        |                [                |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                {                |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |         "offset": 69096,        |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |   "event_log_id": 17263886352   |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                },               |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                {                |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |        "offset": 123520,        |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |   "event_log_id": 17414750224   |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                },               |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                {                |        |             |                           |                           |
|  1  | 0000000C78000010 | regression_pubsub |  false  | regression_pubsub | host.docker.internal:18080 |             |   grpc   |      null      |   {}   |         "offset": 91072,        | null   | null        | 2023-02-07T14:20:18+08:00 | 2023-02-07T14:20:18+08:00 |
|     |                  |                   |         |                   |                            |             |          |                |        |   "event_log_id": 17213489168   |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                },               |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                {                |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |        "offset": 123528,        |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |   "event_log_id": 17247109136   |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                },               |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                {                |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |    "event_log_id": 1728184336   |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                }                |        |             |                           |                           |
|     |                  |                   |         |                   |                            |             |          |                |        |                ]                |        |             |                           |                           |
+-----+------------------+-------------------+---------+-------------------+----------------------------+-------------+----------+----------------+--------+---------------------------------+--------+-------------+---------------------------+---------------------------+

3. What did you see instead (Required)

the event_log_id 17263886352 and 17213489168 can come up with the latest offset

4. What is your Vanus version? (Required)

see docker-compose.yml