ksql-db-create-connector

CREATE SOURCE CONNECTOR tweet_c WITH (
    'connector.class'='com.github.jcustenborder.kafka.connect.twitter.TwitterSourceConnector',
    'twitter.oauth.consumerKey' = 'XXXXXX',
    'twitter.oauth.consumerSecret' = 'YYYYYY',
    'twitter.oauth.accessToken' = 'XXXXXX',
    'twitter.oauth.accessTokenSecret' = 'YYYYYY',
    'process.deletes' = 'false',
    'filter.keywords' = 'trump', 
    'kafka.status.topic' = 'tweet-raw-v2',
    'transforms.createKey.type' = 'org.apache.kafka.connect.transforms.ValueToKey',
    'transforms' = 'createKey,extractInt',
    'transforms.createKey.fields' = 'Id',
    'transforms.extractInt.type' = 'org.apache.kafka.connect.transforms.ExtractField$Key',
    'transforms.extractInt.field' = 'Id'
);