记录一下关于springcloud alibaba的Nacos、Sentinel相关学习笔记，除了方便自己以后查阅也希望能帮到学习的小伙伴，各位看到此博客的小伙伴，如有不对的地方请及时通过私信我或者评论此博客的方式指出，以免误人子弟。多谢！关于它的介绍及功能请看官网，这里贴一下中文的参考地址：参考网址这一篇开始先记录下Nacos相关的东东，主要记录一下Nacos作为服务注册中心和配置中心两部分，即

Linux centos7 安装jdk8的两种方式

目录下载部署相关令名启动Tomcat遇到的错误The Apache Tomcat Native library which allows using OpenSSL was not found on the java.library.path安装Tomcat Native library下载解压配置安装修改 /etc/profile文件修改server.xmlorg.apache.catalina

写在前面：各位看到此博客的小伙伴，如有不对的地方请及时通过私信我或者评论此博客的方式指出，以免误人子弟。多谢！在之前的两篇文章，对于生产者而言，我们做到了使用KafkaTemplate发送消息、将消息发送到指定partition、我们还使用了带回调的addCallback方法判断消息是发送成功还是失败，并做下一步处理，今天再完善一下关于消费者的使用。想个场景，咱们在玩游戏的时候，是不是经常因为队友

写在前面：各位看到此博客的小伙伴，如有不对的地方请及时通过私信我或者评论此博客的方式指出，以免误人子弟。多谢！先看下下面这种情况，程序都出错了，按理说消息也不应该成功@GetMapping("/send9")public void test9(String message) {kafkaTemplate.send(topic, message);throw new RuntimeException

写在前面：各位看到此博客的小伙伴，如有不对的地方请及时通过私信我或者评论此博客的方式指出，以免误人子弟。多谢！前面生产者在发送消息异常的时候提供了事务机制，确保消费者不会接收到一些错误的或者不需要的消息，那么当消费者对消息消费处理的时候如果发生了异常呢，当然也需要处理一下异常了，一般我们在监听方法中，只是监听topic中的数据并消费，如果再try catch捕获并处理的话，则会显得代码块非常臃肿不

写在前面：各位看到此博客的小伙伴，如有不对的地方请及时通过私信我或者评论此博客的方式指出，以免误人子弟。多谢！补充一个简单的东西，生产者监听器，生产者监听器ProducerListener与带回调的kafkatemplate实现类似的功能，或者说是它的一个补充，实现生产者监听器也很简单，只要实现ProducerListener接口，重写onSuccess和onError方法即可，从方法名可看出，o

写在前面：各位看到此博客的小伙伴，如有不对的地方请及时通过私信我或者评论此博客的方式指出，以免误人子弟。多谢！先大体说一下本篇要完成的事：本地连阿里服务器上的kafka向指定topic发送消息项目中创建一个监听类，接收发送的消息，同时在阿里服务器上创建一个消费者接收消息使用kafkaTemplate提供的addCallback方法监控消息是否发送成功，并进行下一步处理消费topic的指定分区数据发

由于Kafka的写性能非常高，因此肯定会碰到Kafka消息队列拥堵的情况。遇到这种情况，我们可以通过并发消费、批量消费的方法进行解决。之前配置生产者我没有在yml文件中直接配置，而是新建了一个配置类，在配置类中配置生产者，这样确实有点麻烦了，所以消费者就直接在yml进行配置了。先看下批量消费，想要批量消费，首先要开启批量消费，通过listener.type属性设置为batch即可开启，看下代码吧：

今天使用Kafka Tools连接阿里云服务器上的kafka时一直连不上 报如下错误：解决方法如下：修改kafka配置文件config/server.properties把31行的注释去掉，listeners=PLAINTEXT://:9092把36行的注释去掉，把advertised.listeners值改为PLAINTEXT://host_ip:9092host_ip为你服务器的ip修改完配置