1.查看所有docker容器查看所有在运行的容器：docker ps查看所有容器(包括停止的) :docker ps -a来看看他们的区别：2.启动容器这里我来启动第二个Redis容器（因为我已经有一个Redis在运行了，所以这次要重新命名并且将端口改成6378）：docker run -itd --name redis02 -p 6378:6378 re...

一.前言： IOC（控制反转）与DI（依赖注入）Spring框架对Java开发的重要性不言而喻，其核心特性就是IOC（Inversion of Control， 控制反转）和AOP，平时使用最多的就是其中的IOC，我们通过将组件交由Spring的IOC容器管理，将对象的依赖关系由Spring控制，避免硬编码所造成的过度程序耦合。在讲依赖注入之前，我觉得有必要了解一下IOC（控制反转）与DI（...

Linux如何批量删除相同类型或者名称相似的文件：命令：删除文件名以jpg或png结尾的文件：rm -rf *@(jpg|png)删除文件名不以jpg结尾的文件：rm -rf !(*jpg)这里要特殊注意，操作要在文件所在的目录下操作才有用：不在一个目录下操作会发现是没用用的进入目标路径下操作就OK了：...

kafka报错：原因出现这种问题的原因主要是因为客户端异常关闭，而服务端还在发送数据所导致的！解决方案先关闭服务端！再关闭客户端~！

目前在做一个项目，需要从第三方通过消息队列拿数据，之前使用的是kinesis，现在需要改成kafka，于是在前期的时候，希望增加一个开关控制是否开启kafka的消息监听。但是在使用kafka的时候,springboot集成 kafka就是直接使用@KafkaListener注解,启用监听就可以了，但是设置监听不监听,还真不知道从哪下手。但是之前也对kafka的消费者做过个性化配置，于是顺着这条线看

今天在自己的服务器上装了一个Kafka，在自己电脑上使用springboot集成kafka，发送消息的时候，报了下面的错误：[customer] 2020-08-13 16:23:32.984 WARN[kafka-producer-network-thread | producer-1] [NetworkClient] [Producer clientId=producer-1] Error c

最近项目中需要对接第三方系统，数据通过kafka传递过来，需要使用到 KafkaAvroDeserializer 来反序列化消息，于是踩坑开始了。首先，我们设置反序列化工具：configs.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, KafkaAvroDeserializer.class);但是会发现找不到KafkaAvroDeseria

我们的业务中使用到了kafka来实现一些功能，但是最近发现经常出现消息丢失的情况，我们用的org.springframework.kafka，配置如下：spring:kafka:producer:bootstrap-servers: xxx:9092key-serializer: org.apache.kafka.common.serialization.StringSerializervalue

比如,我现在想下载 这个jar<dependency> <groupId>io.confluent</groupId> <artifactId>kafka-avro-serializer</artifactId> <version>5.3.0</version> </dependency>在maven官

我们的项目中很多系统交互使用的kafka，最近遇到一个问题，原来我们的kafka需要监听消费我们自己的kafka生产的消息，但是现在需要使用kafka来消费外部系统的消息，但是我们原来的使用非常简单，直接在application.yml中进行的配置，同时监听两个kafka的话，不能实现，于是就要解决这个问题啦。下面是我们之前的配置方式：yml文件中的配置：消费者配置：...