Anqi
Anqi
meta client will retry with the real current leader for LEADER_CHANGE error
look forward to your pr ~
Great issue, We'll support this requirement~
the original intention is to set default value for some configs. But the default value is set in GetOrElse function, so the var looks no useless. we can update it...
the requirement looks like more suitable for flink connector, which is already supported.
Thanks for your contribution for Nebula-Exchange and Nebula-Spark-Connector, now this repo has been split into three different repos, could you please submit two pr to repo https://github.com/vesoft-inc/nebula-exchang and repo https://github.com/vesoft-inc/nebula-spark-connector.
Thanks for your pr to support the parsing for kafka‘s value. This pr changes the architecture of Exchange showed in doc https://docs.nebula-graph.com.cn/2.5.1/nebula-exchange/about-exchange/ex-ug-what-is-exchange/, can we just modify the StreamingReader to parse...
Thanks for your research @spike-liu . I believe it would be more flexible to give the user an option to have exactly-once semantics. 1. FLIP-143 unified the Data Sink API,...
我用这个依赖可以运行的,没有类加载的问题,你看下 你pom.xml中的引用方式 ``` com.vesoft nebula-flink-connector 3.5.0 org.apache.flink flink-streaming-java_2.11 1.14.4 org.slf4j slf4j-log4j12 1.7.25 ```