Jian Yun

可以的,我现在发现了一个转换器，比这两种方案更好用一些，但是api很难用。你可以试试，[ecore](http://cn.epubee.com/ecore.html) 我封装的转换脚本 ```shell #!/bin/bash format=$1 cd "$2" DIR=$(pwd) book_convert(){ filepath=$1 format=$2 tmp_dir="$HOME/Downloads/eCoreCmdtmp/$(uuidgen)" mkdir -p $tmp_dir # rm -rf "$HOME/Downloads/eCoreCmdtmp" dirname=$(dirname "$filepath") basename=$(basename --s .azw3 "$filepath") origin_name=$(basename "$filepath") newfile_neme=$basename"."$format echo "-...

哈哈，没事。ecore我用着还可以。我是从他的电子书管理器里面提取出来的，版本会更新一些😀。

现在是社区贡献，idea真正支持中文版的路应该还很长

Every time I close pulsar's task, there will be these two `pulsar-client-io-6-1` and `pulsar-timer-8-1` threads that are not closed. @codelipenghui @jiazhai Do you have any suggestions to troubleshoot and solve...

@syhily It is not available now, but if you need it, you can put it into the plan.

@longtengz Please tell me the version of the connector you are using~ `PulsarDeserializer` is a class that is about to be deprecated, and it is still used sparingly in the...

Regarding the problem of `org/apache/pulsar/shade/io/netty/buffer/PoolArena$1`, it should be that the same class exists in flink_lib. You can keep any copy. This class is in the `pulsar-client-all` package. Also exists in...

@syhily @longtengz Well, `PulsarDeserializer` is the class that should be dropped

@Johnnyhooyo ~Yes, if you need faster consumption, you can try to increase the parallelism of flink job.~ Sorry, the number of Pulsar topic partitions and Flink parallelism is 1:1 .

@Johnnyhooyo @shulaoh Sorry, the number of Pulsar topic partitions and Flink parallelism is 1:1. This is because the connector uses the Pulsar Reader API to consume data, and the Reader...