affe (Yufei Zhang)

This sounds like a new feature. It would be nice if you are interested in providing a solution, and we will look into this as well ~

Trying to debug why rebalance service is trying to create new task with a deleted task configuration for both source and sink connectors. ``` 020-04-01 01:35:53 INFO RebalanceService - Allocated...

We (me and @gripson) found a bug in jdbc-connector. when creating DruidDataSource in `DBUtils.java` ``` Map map = new HashMap(); map.put("driverClassName", "com.mysql.cj.jdbc.Driver"); map.put("url", "jdbc:mysql://" + config.getDbUrl() + ":" + config.getDbPort()...

Recorder: a possible cause for `stopAll` not working here,`connectorConfig` declared but not used. ``` @Override public void removeConnectorConfig(String connectorName) { ConnectKeyValue config = new ConnectKeyValue(); config.put(RuntimeConfigDefine.UPDATE_TIMESATMP, System.currentTimeMillis()); config.put(RuntimeConfigDefine.CONFIG_DELETED, 1); //...

Another place that causes `fetch topicList error` after `stopAll` command is that in jdbc sink connector is not stopped properly. The `stopAll` relies on each connector's `stop` method, but in...

In runtime `WorkerSinkTask`, in the `run()` method ``` while (!isStopping.get()) { // TODO if isStopping == False then entered this section pullMessageFromQueues(); } ``` and a `stop()` method where isStopping...

Cassandra driver jar needs to be put under classpath (reference.conf needs to be found under classpath), currently not sure if the plugin path is under classpath. Now my solution for...

I was trying to solve this Cassandra driver related error. I met this as well when I was testing the driver with a demo project. Stackoverflow says it is because...

WorkerSinkTask#pullMessageFromQueues(), this method can block up to 20 seconds, however the consumer pull timeout is set to 3 seconds, which is very weird. 1. We need to find out why...

**Cassandra datastax driver depends on a netty version conflict with the rocketmq netty dependency.** Using the official non-shaded datastax-java-driver would result in following error message when trying to create a...