rocketmq-flink

rocketmq-flink copied to clipboard

[#35] Use `LitePullConsumer` model instead of default pull consumer

4

close #35 Use `DefaultLitePullConsumer` model instead of default pull consumer. Tips Thank you very much for contributing to Apache rocketmq-flink. What is the purpose of the pull request *solve some...

galaxy077

Port RocketMQSink to FLIP-143

1

Port RocketMQSink to FLIP-143

GOODBOY008

[Polish] Move example code to somewhere?

1

GOODBOY008

org.apache.rocketmq:schema-registry-client non-existent

2

org.apache.rocketmq:schema-registry-client non-existent

chaotianque

have or not a plan to split flink/rocketMq different version for more flexible version adaptation in flink and rocketMq

Ink00Bamboo

Are you using RocketMQ Flink?

8

## Are you using RocketMQ Flink? If you are using RocketMQ Flink, first we would like to Thank You. Here, we sincerely invite you to take a minute to feedback...

SteNicholas

Use litePullConsumer model instead of default pull consumer.

3

See description in RocketMQ, ``` /** * @deprecated * Default pulling consumer. * This class will be removed in 2022, and a better implementation {@link DefaultLitePullConsumer} is recommend to use...

ShannonDing

How do I set up stateBackend and save checkpoints in HDFS?

SOD-DOB

The following files had format violations: [ERROR] src/main/java/org/apache/rocketmq/flink/sink/table/RocketMQDynamicTableSink.java [ERROR] @@ -199,7 +199,8 @@ [ERROR] ········return·producerProps; [ERROR] ····} [ERROR] [ERROR] -····protected·static·RowTypeInfo·convertToRowTypeInfo(DataType·fieldsDataType,·String[]·fieldNames)·{ [ERROR] +····protected·static·RowTypeInfo·convertToRowTypeInfo( [ERROR] +············DataType·fieldsDataType,·String[]·fieldNames)·{ [ERROR] ········final·TypeInformation[]·fieldTypes·= [ERROR] ················fieldsDataType.getChildren().stream() [ERROR] ························.map(LegacyTypeInfoDataTypeConverter::toLegacyTypeInfo)...

galaxy077

Message order needs to be guaranteed

duhenglucky