apache-kafka - 使用 KSQL 在 kafka 主题上创建流
问题描述
以下是我来自 kafka 主题的示例日志
2019-03-04T08:53:03.023Z "cd8cbe" 100.212.212.212 - - [20/Feb/2019:12:13:33 +0000] "GET http://dl-mysite.com/drm/PRIORITY1080/HINDI_MOVIES/somemovie.mp4/video/avc1/4/seg-1281.m4s HTTP/1.1" 200 325040 "-" "Dalvik/2.1.0 (Linux; U; Android 6.0; Le X509 Build/DHXOSOP5801911241S)" "256" "0.000"
我正在尝试使用 KSQL 在上述主题上创建流。下面是我用来创建流的脚本。运行以下流创建脚本后,它返回“流创建”消息,但是选择语句(select * from test_duplicate_stream;)不返回任何内容。
CREATE STREAM test_duplicate_stream (logArrivalTime varchar,edgeid varchar,ip varchar,col1_empty varchar,col2_empty varchar, eventdate varchar,url varchar,response_code int,response_length BIGINT,col3_empty varchar,user_agent varchar,request_length varchar, response_time varchar) WITH (kafka_topic='test_duplicate',VALUE_FORMAT='DELIMITED');
我相信“DELIMITED”不是在这里使用的正确值,因为我的字段不是逗号分隔而是空格分隔。为我的日志线创建流的正确方法是什么?
解决方案
推荐阅读
- jquery - jquery toggleClass 视图没有变化
- reactjs - 无法在reactjs中呈现数据表的数据
- ios - 如何制作可展开的侧边菜单 tableView 列表
- javascript - 如何对 Steam 市场 JSON 数据进行排序
- magento-2.3 - 无法发送 cookie。报告中“mage-messages”的大小为 4190 字节
- python - 如何在 QMenuBar 中移动项目(菜单)?
- operating-system - 在 AUTOSAR 中进行硬复位和软复位后 OS 和 ECUM 的行为
- r - 删除行的大部分值为零
- java - EC2 实例 - 将 STDOUT 日志发送到 Cloud Watch
- apache-spark - Spark 中的 accumulator 和 collect() 之间的性能差异是什么?