http://edisonxu.com/2018/12/04/akka-kafka-consumer.html
核心API在使用Akka kafka consumer前, 先了解下几个核心API: ConsumerSetting Consumer的配置信息; ConsumerRecord Kafka消息的封装类,包含消息的K、V,以及该消息所属的topic, partition, offset, timestamp等; ConsumerMessage 是ConsumerRecord的进一步充血模型,提供了
http://edisonxu.com/2018/12/04/akka-kafka-consumer.html
核心API在使用Akka kafka consumer前, 先了解下几个核心API: ConsumerSetting Consumer的配置信息; ConsumerRecord Kafka消息的封装类,包含消息的K、V,以及该消息所属的topic, partition, offset, timestamp等; ConsumerMessage 是ConsumerRecord的进一步充血模型,提供了