标签:producer 基于 一个 nbsp 订阅 sum 轮询 serve div
1.消费者用--bootstrap-server方式启动,消费的偏移量offset保存在broker的一个主题_consumer_offsets里,此主题默认50个分区。
2.zk中的version-2文件夹存储了关于kafka的一些数据。
3.server.properties里的log.dir项配置的是主题里的数据,而不是日志。日志文件夹会自动生成,无需配置。
4.kafka是基于发布订阅模式的消息中间件,由消费者根据自身的消费能力,主动拉取数据,需要维护一个长轮询。
5.不同分区数据的便宜量都是从0开始,没有一个全局的统一偏移量。
6.生产者分区原则。我们需要将 producer 发送的数据封装成一个 ProducerRecord 对象。
标签:producer 基于 一个 nbsp 订阅 sum 轮询 serve div
原文地址:https://www.cnblogs.com/noyouth/p/12819810.html