2024年2月28日 - 51CTO博客热门标签flink 消费kafka sink到hdfs .问题描述最近在开发flink程序时,需要开窗计算人次,在反复测试中发现flink的并行度会影响数据准确性,当...

2014年7月22日 - /usr/lib/kafka-current/bin/kafka-topics.sh --partitions 10 --replication-factor 2 --zookeeper emr-header-1:2181 /kafka-1.0.0 --topic payment...