Add support for KSQLDB Source Tables

[rodgers-mmsi]

The current implementation does not support creating source tables - i.e. CREATE TABLE statements that have the "SOURCE" clause. See here for details.

So, for example, if you have a source table defined as this:

CREATE SOURCE TABLE other_status_codes (code int primary key, definition varchar)
    with (kafka_topic = 'other_status_codes', value_format = 'json');

The pipelineExecute task succeeds the first time only. Running the pipelineExecute task a second time does not succeed - giving an error that the table "other_status_codes" exists. The task did not generate a DROP TABLE statement in the script.

Fair warning - I'm not a Groovy developer, so this may not be the most elegant way to fix the plugin, but it works, similar to the existing handling of source/sink connectors.

[stewartbryson]

/gcbrun

[stewartbryson]

@rodgers-mmsi Sorry this got passed me. If you are still interested in me merging this, can you merge the latest changes into your branch?

[stewartbryson]

Received this error during unit tests:

Caused by: org.gradle.api.GradleException: error_code: 40001: line 1:15: mismatched input 'TABLE' expecting 'CONNECTOR'

[stewartbryson]

/gcbrun