-
yexindonglai@163.com
2022-03-01 10:19
Kafka
1396°
0
mq是什么有broker的mq(有中转站)什么是topic重topic轻topic没有broker的mq(没中转站)消息队列的分类kafkakafka特点消息处理的三种语义1、atleastonce2、atmostonce3、exactlyonce偏移量消费组comsumerGroup单播消息多播消息消费组信息分区partition分区如何存储数据kafks默认主题_consumer_offsets_consumer_offsets主题的分区保存时长副本集群消费细节生产者发送消息-同步和异步同步和异步哪个用的多?产生的问题有哪些kafka消息消费模式推送模式push拉取模式pollmq是什么m
-
yexindonglai@163.com
2022-03-01 10:19
Kafka
1476°
0
1、防止消息丢失发送方消费方2、重复消费(幂等性问题)3、消息积压消息积压的原因消息积压出现的问题消息积压解决方案4、延时队列延时使用场景如何实现延时队列5、顺序消费发送方(生产者)接收方(消费者)顺序消费产生的问题1、防止消息丢失发送方将ack设为1或者-1/all,可以防止消息丢失;如果要做到99.99999%防止丢失,把ack设为all,把min.insync.replicas设为你的集群分区副本的数量即可;#表示要将消息刷入集群环境的2个副本中后,才会返回ack;min.insync.replicas=2消费方把自动提交改为手动提交,也就是说当我消费成功后才会进行提交。如果设为自动提交
-
yexindonglai@163.com
2022-03-01 10:18
Kafka
3138°
0
[TOC][TOC]前言最近在部署kafka单节点时遇到的问题,想着自己弄个单节点演示以下,好家伙,单启动的时候就报了很多错误;为防止在坑,故将错误信息记录下来;以防万一!kafka版本2.4.1部署环境阿里云服务器,系统为centos7.9解决kafka启动报错:Socketserverfailedtobindto123.57.207.179无法指定被请求的地址.控制台整体错误信息如下[2021-09-1410:59:11,134]ERROR[KafkaServerid=0]FatalerrorduringKafkaServerstartup.Preparetoshutdown(kafka.