多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
* Topic * Topic是已发布消息的类别名称 * 发布和订阅数据必须指定Topic * <mark>Topic副本数量不大于Brokers个数,即不能多于服务器的数量</mark> * 创建的Topic存储在 {kafka_home}/config/server.properties 指定的`log.dirs`路径中 Topic是已发布消息的类别名称,里面存储一条条的 key-value 消息。每条消息的Key 及 Value 都有相应的序列化方式,通常是在 Producer 生产消息时指定相应的序列化器,而 Consumer 消费时使用相应的反序列化器,在实际应用时生产者与消费者应该约定统一的序列化方式。Topic 又分为多个不同的分区(Partition),每一条消息都由分区策略控制该消息应该存储在哪个分区之中,并由各分区相应的偏移量(Offset)唯一标识。