Xiaojian Sun
Xiaojian Sun
> Hi @sunxiaojian You can add a public method to get the AssignedMessageQueue. OK Another question is whether an interface can be added to submit the offset specified by the...
> > Member > > Maybe DefaultLitePullConsumer.commit(final Set messageQueues, boolean persist) can meet your needs. DefaultLitePullConsumer.commit can't specify offset. I provided PR for support. Can you help review it? https://github.com/apache/rocketmq/pull/4820
> @sunxiaojian Can you please rebase your PR? @MartijnVisser Thanks for your review, it has been processed
> > Thanks for your review, it has been processed > > CI is failing, will you take a look? @MartijnVisser fixed
> @sunxiaojian have you considered implementing this as a Flink format? You could draw inspiration from pre-existing formats: https://github.com/apache/flink/tree/master/flink-formats/flink-json/src/main/java/org/apache/flink/formats/json > > For example, the debezium json format already has an...
@FangYongs @schnappi17 PTAL cc @JingsongLi
@FangYongs @schnappi17 When you have time, please take a look at this PR
@FangYongs @schnappi17 Do we need to send an email to discuss the part of this optimization ?
related https://github.com/apache/seatunnel/pull/3981