You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Written variously: I think KafkaExtractNode should support more KafkaScanStartupMode. Currently, only two types of KafkaExtractNode are supported, including EARLIEST_OFFSET and LATEST_OFFSET, But in many cases topicPartitionOffset is specified, and this parameter is already reserved in KafkaSource,I'd like to contribute this code if I can
Yeah sure, thanks for participation, note that now SPECIFIC_OFFSETS is currently support by KafkaDynamicTableFactory. Please be aware of that the specificStartupOffsets should also be passed to the factory when doing so
Yeah sure, thanks for participation, note that now SPECIFIC_OFFSETS is currently support by KafkaDynamicTableFactory. Please be aware of that the specificStartupOffsets should also be passed to the factory when doing so
Ok, I'll take care of that
huyuanfeng2018
changed the title
[Improve] KafkaExtractNode support more StartupMode
[Improve][Sort] KafkaExtractNode support more StartupMode
Jul 16, 2022
Description
Written variously: I think KafkaExtractNode should support more KafkaScanStartupMode. Currently, only two types of KafkaExtractNode are supported, including EARLIEST_OFFSET and LATEST_OFFSET, But in many cases topicPartitionOffset is specified, and this parameter is already reserved in KafkaSource,I'd like to contribute this code if I can
InLong Component
InLong Sort
Are you willing to submit PR?
Code of Conduct
The text was updated successfully, but these errors were encountered: