批次
说明:在kafka中消息是按照一个批次一个批次发送给kafka服务器的。(减少推送请求)
主题
说明: 即顾名思义,消息的主题
分区
说明:一个主题拥有多个分区
偏移量
消费者群组
说明:作为一个群组内,一个主题下的一个分区只属于群组内的一个消费者,用于区分。
kafka安装环境+部署
可参考如下网址
硬件配置对Kafka的影响
IO对生产者有影响,因为生产者需要写数据
内存对消费者有影响,因为读取消息从内存中读取
kafka生产者消息发送(生产者对象是线性安全,所以只要一个生产者对象即可。)
acks 必须要多少个分区副本接收到了消息
参数有 0 、1(默认)、 all (可靠性最高、延迟高)
Future模式,等待发送成功回调
回调模式Callback