[inlong] branch master updated (c97791057 -> 67d89b384)

[do...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from c97791057 [INLONG-5423][Sort] Revise invalid partition time when dispatch messages (#5438)
     add 67d89b384 [INLONG-5418][SDK] Sort SDK support seek topic or partitions to a given timestamp (#5441)

No new revisions were added by this update.

Summary of changes:
 .../inlong/sdk/sort/api/InLongTopicFetcher.java    |  20 +++-
 .../apache/inlong/sdk/sort/api/Interceptor.java    |   9 +-
 .../sdk/sort/api/{Interceptor.java => Seeker.java} |  31 +++---
 .../api/{EmptyListener.java => SeekerFactory.java} |  32 +++----
 .../apache/inlong/sdk/sort/entity/InLongTopic.java |   9 +-
 .../sdk/sort/impl/QueryConsumeConfigImpl.java      |   1 +
 .../sort/impl/interceptor/MsgTimeInterceptor.java  |  13 ++-
 .../sdk/sort/impl/kafka/AckOffsetOnRebalance.java  |  15 +--
 .../sort/impl/kafka/InLongKafkaFetcherImpl.java    |   5 +-
 .../inlong/sdk/sort/impl/kafka/KafkaSeeker.java    | 106 +++++++++++++++++++++
 .../sort/impl/pulsar/InLongPulsarFetcherImpl.java  |  32 ++++++-
 .../inlong/sdk/sort/impl/pulsar/PulsarSeeker.java  |  63 ++++++++++++
 .../sdk/sort/impl/tube/InLongTubeFetcherImpl.java  |   5 +-
 .../impl/pulsar/InLongPulsarFetcherImplTest.java   |   1 +
 .../sort/standalone/sink/cls/ClsSinkContext.java   |  18 ++--
 15 files changed, 297 insertions(+), 63 deletions(-)
 copy inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/{Interceptor.java => Seeker.java} (64%)
 copy inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/{EmptyListener.java => SeekerFactory.java} (54%)
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/kafka/KafkaSeeker.java
 create mode 100644 inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/pulsar/PulsarSeeker.java