分布式复习--Kafka二

消息确认的几种方式 自动提交 手动提交 手动异步提交 consumer. commitASync() //手动异步ack 手动同步提交 consumer. commitSync() //手动异步ack 指定消费某个分区的消息 消息的消费原理 （0.8版本之前）之前Kafka存在的一个非常大的性能隐患就是利用ZK来记录各个Consumer Group的消费进度（offset）。当然JVM Clien

>>阅读原文<<