fieldSchema for field group_id cannot be null

[sharooque7]

When using Kafka TDengineSourceConnector. I have encountered the below issue.

This issue occurs when i create a stream(Stream Processing).

{
  "name": "TDengineSourceConnector",
  "connector": {
    "state": "RUNNING",
    "worker_id": "172.24.0.4:8083"
  },
  "tasks": [
    {
      "id": 0,
      "state": "FAILED",
      "worker_id": "172.24.0.4:8083",
      "trace": "org.apache.kafka.connect.errors.SchemaBuilderException: fieldSchema for field group_id cannot be null.\n\tat org.apache.kafka.connect.data.SchemaBuilder.field(SchemaBuilder.java:327)\n\tat com.taosdata.kafka.connect.source.TableMapper.getMetaSchema(TableMapper.java:102)\n\tat com.taosdata.kafka.connect.source.TableMapper.getOrCreatePreparedStatement(TableMapper.java:56)\n\tat com.taosdata.kafka.connect.source.TableMapper.<init>(TableMapper.java:49)\n\tat com.taosdata.kafka.connect.source.JsonMapper.<init>(JsonMapper.java:24)\n\tat com.taosdata.kafka.connect.source.TableExecutor.<init>(TableExecutor.java:65)\n\tat com.taosdata.kafka.connect.source.TDengineSourceTask.start(TDengineSourceTask.java:98)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.initializeAndStart(AbstractWorkerSourceTask.java:278)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doStart(WorkerTask.java:175)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:224)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:280)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:78)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:829)\n"
    }
  ],
  "type": "source"
}

[sharooque7]

The issue is that data type: BIGINT UNSIGNED is not handled in connector schema.

Upon handling this case the connectors is not breaking even when i create a stream alongside Kafka connector.

I have a some doubts

1. Is the connector is build intentionally to fail when working with stream.
2. As i have seen the stream is respected for all Databases inside single instance. Even if i create stream inside one DB (say TestA) and use Kafka connector for another DB (TestB ) still connector fails.