[Bug] [Kafka] Sync Task of kafka throws npe.

[FlechazoW]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

When i submit a sync task of kafka, task failed and thrown a nullpoint exception.

What you expected to happen

Task should succeed.

How to reproduce

Job content:

{
  "job": {
    "content": [
      {
        "reader": {
          "parameter": {
            "topic": "tiezhu_in_one",
            "mode": "earliest-offset",
            "offset": "EARLIEST",
            "groupId": "*",
            "codec": "json",
            "column": [
              {
                "name": "id",
                "type": "int"
              },
              {
                "name": "name",
                "type": "String"
              }
            ],
            "consumerSettings": {
              "bootstrap.servers": "flink01:9092,flink02:9092,flink03:9092",
              "auto.commit.enable": "false"
            }
          },
          "name": "kafkasource"
        },
        "writer": {
          "name": "streamwriter",
          "parameter": {
            "print": true
          }
        }
      }
    ],
    "setting": {
      "restore": {
        "isRestore": true,
        "isStream": true
      },
      "speed": {
        "readerChannel": 1,
        "writerChannel": 1
      }
    }
  }
}

Anything else

No response

Version

master

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct