hww123 removed a comment on issue #1790: doris对于实时流处理的支持 URL: https://github.com/apache/incubator-doris/issues/1790#issuecomment-603060496 > 这里可以直接将数据写入kafka，然后doris订阅那个主题进行存储就行了，我们刚开始用的时候没有注意有这么个功能 在 2020-03-09 14:12:41，"z-Dapor" <[email protected]> 写道： 最后采用http的方式在flink流程中缓存后再定时或定量批量进行导入总算打通流程了 大概缓存的数量和占用的内存大概多少呢？一批多少数据？ — You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub, or unsubscribe. 你好，想问一下 你用kafka订阅的方式，那么kafka发消息的api是怎么写的？ 官方说csv格式，我用new ProducerRecord(topic, partition, timestamp, key,value) 然后 value 是 xx,xx,xx,xx 对应表的4个字段按顺序.但是SHOW ROUTINE LOAD TASK WHERE JobName =topic 没有报错日志 表也没有数据导入进去，topic是有消息数据的。
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
