高思伟

bugs about `RockerMQSource` in current master branch: - [x] [bug]PartitionDiscoveryIntervalMs can't set to negative - [x] [bug]Idle source task can't be released automatic - [x] [bug]Offset didn't commit to broker...

> LGTM. Thanks for @deemogsw contribution. BTW, @deemogsw have you tested this on local environment? Yes,I have test this case.We found the bug in produce environment. We can simulate the...

An exception can't be throwed in rmq-pull-thread,So function of `run` can't catch exception and flink still believes that the program has no exceptions.

- [x] [bug]PartitionDiscoveryIntervalMs can't set to negative - [x] [bug]Idle source task can't be released automatic - [x] [bug]Offset didn't commit to broker in `RockerMQSource` in phase of checkpoint -...

As description in issue #69 ,branch of master has some bugs with pr #46 .So my branch still be dependent on common pull mode. I will complete the README.md with...

> @deemogsw Thanks for your contributions! Can you rebase to last main branch. Main branch has bug in litepull consumer.I have mentioned in issue #69 .You can also have a...

please reset the branch of master to 90b00be02dd019ffed48cbc35cd050b07c4a36ab.The pr of #46 has some bugs and author has not fixed it yet. You can look the detail of this bug in...

@SteNicholas @zhouxinyu Please pay attention to this problem，thanks

Maybe It has another problems.For testing ,i run the V4.8 in docker container.But it is still failed So I read the documents again.In Assign mode,consumer must assign MessageQueues before seek...

> is there any progress ? The original contributors disappeared and have not fix this problem.Maintainer also rarely manage. You can visit my homepage for project of rocketMQ-flink-connector.This is the...