CREATE EXTERNAL TABLE sales_kafka (
order_id BIGINT,
product_id INT,
quantity INT,
timer DATETIME
)
ENGINE=KAFKA
PROPERTIES ("kafka.bootstrap.servers"="XXXX:9092",
"kafka.topic"="T_MD_C",
"kafka.key.format"="json",
"kafka.value.format"="json",
"column_separator"=","
);
使用连接KAFKA时报错1105 - errCode = 2, detailMessage = Do not support external table with engine name = olap
请问使用这种方式是否可以连接KAFKA,如果可以上面这段脚本该如何修改,ENGINE=OLAP也不行。