发布网友
共1个回答
热心网友
Kafka stream groupby 数据不准确是集群的问题。
Kafka Stream是Apache Kafka的主要功能,用于实时转换和组合数据流,Kafka Stream是用于消费来自Kafka topic产生的数据,该库包并没有后压back-pressure 机制,一个 topology在某个时间处理一个元素,所谓topology是由多个源topic, 许多连接到流操作的数据处理器和多个sink topic组成。Kafka Stream会缓冲即将被kafka消费者拉取的元素,以及缓冲由Kafka生产者委托的即将进行批写入的元素。这会大大简化了设计,注意:不支持异步操作,所以,你不能在你的数据处理器中有任何堵塞操作,否则会堵塞整个流。