9092
-
kafka-常用命令
常用命令 创建Topic： ./kafka-topics.sh –bootstrap-server localhost:9092 –create –topic shixTop…
-
kafka~消费群组如何重新消费
今天遇到一个问题，由于代码问题导致了很多kafka消息入到备用库，偏移量已经变成了最新；如何将偏移量重设到某个时间点，但消费群组重新去消费一次，是解决问题的关键，于是，使用了kaf…
-
Flink SQl 语法(hint,with,select,分组窗口聚合，时间属性（处理，事件）)
6、Flink SQl 语法 1、查询语句 1、hint 在对表进行查询的是偶动态修改表的属性 — 创建表 CREATE TABLE word ( lines STRING ) …