Kafka集群搭建

一，集群搭建 1.1 重要原则 Kafka节点只要注册到同一个Zookeeper上就代表它们是同一个集群的 Kafka通过broker.id来区分集群中的不同节点 1.2 规划 简单起见，我们只使用一个VMWare虚拟机，所以各个broker实例需要设定不同端口号 Kafka程序不需要复制，对应各自

SpringBoot集成Kafka

一，Spring Boot集成Kafka快速入门 1.1 环境准备 确保你的Kafka已启动： kafka-topics --list --bootstrap-server localhost:9092 1.2 创建Spring Boot项目 项目结构： kafka-springboot-demo

Java操作Kafka

一，快速入门 引入maven依赖 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>4.2.0</version> </depend

Kafka基础操作

一，Web-Ui操作Kafka 先安装Kafka-ui docker run -d \ --name kafka-ui \ -p 8080:8080 \ -e DYNAMIC_CONFIG_ENABLED=true \ -e KAFKA_CLUSTERS_0_NAME=local \

Kafa基础介绍

一、Kafka介绍 Kafka是Apache开源的一款基于zookeeper协调的分布式消息系统，具有高吞吐率、高性能、实时、高可靠等特点，可实时处理流式数据。它最初由LinkedIn公司开发，使用Scala语言编写。 Kafka历经数年的发展，从最初纯粹的消息引擎，到近几年开始在流处理平台生态圈发

RabbitMQ进阶

一，发送者的可靠性 首先，我们一起分析一下消息丢失的可能性有哪些。 消息从发送者发送消息，到消费者处理消息，需要经过的流程是这样的： 消息从生产者到消费者的每一步都可能导致消息丢失： 发送消息时丢失： 生产者发送消息时连接MQ失败 生产者发送消息到达MQ后未找到Exchange 生产者发送消息到达M

Java操作RabbitMQ

SpringAMQP 将来我们开发业务功能的时候，肯定不会在控制台收发消息，而是应该基于编程的方式。由于RabbitMQ采用了AMQP协议，因此它具备跨语言的特性。任何语言只要遵循AMQP协议收发消息，都可以与RabbitMQ交互。并且RabbitMQ官方也提供了各种不同语言的客户端。 但是，Rab

RabbitMQ基础

一，MQ介绍 微服务一旦拆分，必然涉及到服务之间的相互调用，目前我们服务之间调用采用的都是基于OpenFeign的调用。这种调用中，调用者发起请求后需要等待 服务提供者执行业务返回结果后，才能继续执行后面的业务。也就是说调用者在调用过程中处于阻塞状态，因此我们称这种调用方式为同步调用，也可以叫 同步

Java操作ES

一，RestAPI操作索引库 1.1 初始化RestClient 在elasticsearch提供的API中，与elasticsearch一切交互都封装在一个名为RestHighLevelClient的类中，必须先完成这个对象的初始化，建立与elasticsearch的连接。 分为三步： 在item

Elasticsearch基础

一，Elasticsearch介绍 1.1 认识Elasticesarch Elasticsearch是由elastic公司开发的一套搜索引擎技术，它是elastic技术栈中的一部分。完整的技术栈包括： Elasticsearch：用于数据存储、计算和搜索 Logstash/Beats：用于数据收集