溪云山雨

摘要： Flink起源 德國柏林 Flink的目標 低延遲 高吞吐 較高的準確性（亂序數據的處理） 良好的容錯性（容錯性差的表現：一個節點掛了，全部回滾重新做計算，這對實時性要求高的場景非常致命） 閱讀全文

摘要： Producer Kafka源碼的exmaple模塊有一個Producer類，繼承了Thread類，構造方法會指定topic，是否異步，是否冪等，配置Kafka集群信息，初始化一個KafkaProducer主線程，它會分別初始化一個攔截器，kv序列化器，分區選擇器（均勻分配消息到不同分區，也可以使用 閱讀全文