logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

kafka系列(15):集群配置参数server.properties

offsets.topic.replication.factor=3解释:该值默认为1。表示kafka的内部topic consumer_offsets副本数。当该副本所在的broker宕机,consumer_offsets只有一份副本,该分区宕机。使用该分区存储消费分组offset位置的消费者均会收到影响,offset无法提交,从而导致生产者可以发送消息但消费者不可用。所以需要设置该字段的值大于

kafka多个consumer同时消费一个topic数据

需求:一个topic消息队列设置3个partitions分区,设置一个group组中3个consumer进行消费注意点:一个group中的consumer数 需小于 topic中的partitions分区数(一个partitions只能被一个consumer进行消费;一个consumer可以消费多个partitions)kafka命令:查看topic详情:./bin/kafka-topics.sh

#kafka
kafka系列(09):SpringBoot 中使用@KafkaListener详解与使用

说明从2.2.4版开始,您可以直接在注释上指定Kafka使用者属性,这些属性将覆盖在使用者工厂中配置的具有相同名称的所有属性。您不能通过这种方式指定group.id和client.id属性。他们将被忽略;可以使用#{…​}或属性占位符(${…​})在SpEL上配置注释上的大多数属性。比如:@KafkaListener(id = "consumer-id",topics = "SHI_TOPIC1"

到底了