[INLONG-314] Support consumpe data in the specified offset interval

apache / inlong

Apache InLong - a one-stop, full-scenario integration framework for massive data

https://inlong.apache.org/

Apache License 2.0

1.4k stars 530 forks source link

[INLONG-314] Support consumpe data in the specified offset interval #913

Closed dockerzhang closed 3 years ago

dockerzhang commented 3 years ago

Recently, we wanted to introduce TubeMQ into Kylin, but we found that TubeMQ could not meet the usage scenarios of Kylin. Therefore, we hope that TubeMQ provides the following functions:

1. Support to get the maximum offset of every partitions
2. consume a specify partition
3. Support consumpe data in the specified offset interval

JIRA link - [INLONG-314] created by gxcheng

gosonzhang commented 3 years ago

Closed due to long periods of inactivity

Please reopen it if needed