📄️ 生产者
生产者,顾名思义:就是产生消息的实体。创建kafka生产者时,有哪些必要的配置项?简单说明这些配置项的作用。发送消息时如何实现消息压缩?
📄️ 消费者与消费者群组
消费者就是通过订阅一个或多个主题,消费消息的实体。消费者从属于消费者群组,一个群组内的多个消费者通过分区分配来接收不同分区的消息。
📄️ 分区的特性
写入消息和消费消息时都需要指定主题(Topic),消息是按主题来分类的。每个主题可以有多个分区(Partition),每个分区同一时间只能被一个消费者消费。通过把多个分区分散到多个服务器上,可以提高系统的服务能力。消息以追加的方式写入分区,然后以先进先出的顺序读取。
📄️ 延时队列
在kafka中要如何实现延时队列呢?很遗憾kafka官方到目前为止并没有给出延时队列的直接实现。也就是说我们需要自己来实现这一部分的功能。
📄️ 事务使用示例
本文档对kafka事务作一个简单的说明,同时给出java代码示例,并对代码做一些简单的说明,同时说明相关的注意事项。希望能对需要使用kafka事务的朋友有帮助。