ksql_reinvent_create_stream.sql

CREATE STREAM twitter_raw 
(CreatedAt bigint,
 Id bigint, 
 Text VARCHAR, 
 SOURCE VARCHAR, 
 Truncated VARCHAR, 
 InReplyToStatusId VARCHAR, 
 InReplyToUserId VARCHAR, 
 InReplyToScreenName VARCHAR, 
 GeoLocation VARCHAR, 
 Place VARCHAR, 
 Favorited VARCHAR, 
 Retweeted VARCHAR, 
 FavoriteCount VARCHAR, 
 User VARCHAR, 
 Retweet VARCHAR, 
 Contributors VARCHAR, 
 RetweetCount VARCHAR, 
 RetweetedByMe VARCHAR, 
 CurrentUserRetweetId VARCHAR, 
 PossiblySensitive VARCHAR, 
 Lang VARCHAR, 
 WithheldInCountries VARCHAR, 
 HashtagEntities VARCHAR, 
 UserMentionEntities VARCHAR, 
 MediaEntities VARCHAR, 
 SymbolEntities VARCHAR, 
 URLEntities VARCHAR) 
WITH (KAFKA_TOPIC='twitter_json_01', 
      VALUE_FORMAT='JSON');