首页 > TAG信息列表 > configprops
kafka入门到精通
kafka 一、kafka基础术语 1.1 Topic 主题，使用类别属性划分消息所属类，而划分消息的类称之为topic 1.2 Partition 分区，topic中的消息被分割为一个或多个partition，对应到系统上就是一个或多个目录，FIFO队列，能保证局部有序 注意：消费者和分区关系，一个consumer可以对应多个分区，但是一个分Spring Boot 2.3 新特配置文件属性跟踪
背景 当我们使用 spring boot 在多环境打包，配置属性在不同环境的值不同，如下： spring: profiles: active: @project.profile@ #根据maven 动态配置profile --- spring: profiles: dev demo: lengleng_dev --- spring: profiles: prd demo: lengleng_prd 或者使用 springkafka将消费进度重置到最新的位置
/** *重置kafka消费进度 *参数中需要指定kafka集群中一台broker地址，要重置的topic名称，消费组，以及partition个数 */public static void seekLatest(String broker, String topic, String group, int partitionCnt){ Map<String, Object> configProps = new HashMap<>Kafka——SpringBoot整合（消费者位移的提交）
消费者位移的提交方式以及提交时机需要根据不同的业务场景进行选择，可以看之前的博客kafka消费者相关。 这里只做应用相关，更多的使用场景，该怎么用、何时用要看前面的博客了解原理。 参考博客：https://blog.csdn.net/yy756127197/article/details/103895810 自动提交偏移量 // 自Kafka——SpringBoot整合（消费者）
目录 单线程消费 pom consumerConfig consumer 批量消费 javaConfig 消费者 BatchConsumer 选择自动提交还是手动提交方式和业务场景相关，可以查看前面的博客，根据原理进行选择。 单线程消费 pom <dependency> <groupId>org.springframework.boot</grou