kafka-sink support

[lingya]

No description provided.

[lingya]

Kafka09 ：
create OUTPUT table topic(
messages varchar
) with (
type = 'kafka09',
kafka_topic = 'T1',
msg_format='json', //messages send format
partitionKey ='eventtime',
"zookeeper.connect" = 'zk:2181'
);

@harbby Is this syntax okay？

[harbby]

Hi @lingya , Thank you very much for your contribution, your design is very good, I have made some expansions.

create OUTPUT table topic(
    event_time long, --Can not(高版本kafka 允许设置该时间)
    partition long,   --Can not(可以没有) 
    key varchar,    -- Can not(可以没有)
    message varchar  -- or binary
) with (
       type = 'kafka09',
       kafka_topic = 'T1',
       kafka_brokes = 'localhost:9092'
       zookeeper_connect" = 'zk:2181'
);

[lingya]

It‘s my pleasure.