kafka(二)

批次

说明:在kafka中消息是按照一个批次一个批次发送给kafka服务器的。(减少推送请求)

主题

说明: 即顾名思义,消息的主题

分区

说明:一个主题拥有多个分区

偏移量

kafka(二)

消费者群组

说明:作为一个群组内,一个主题下的一个分区只属于群组内的一个消费者,用于区分。

kafka(二)

 kafka安装环境+部署

可参考如下网址

Apache Kafka 安装步骤_w3cschool

Apache Kafka 基本操作_w3cschool

硬件配置对Kafka的影响

IO对生产者有影响,因为生产者需要写数据

内存对消费者有影响,因为读取消息从内存中读取

kafka生产者消息发送(生产者对象是线性安全,所以只要一个生产者对象即可。

acks 必须要多少个分区副本接收到了消息

参数有 0  、1(默认)、   all (可靠性最高、延迟高)

Future模式,等待发送成功回调

kafka(二)

回调模式Callback

kafka(二)

上一篇:kafka的ProducerListener为什么能监听到生产者是否发送成功失败


下一篇:kafka读书笔记(二)浅谈生产者