一、概念2、应用场景异步处理系统解耦流量削峰日志处理3、消息队列的两种模式点对点模式消息发送者生产消息发送到消息队列中，然后消息接收者从消息队列中取出并且消费消息。消息被消费以后，消息队列中不再有存储，所以消息接收者不可能消费到已经被消费的消息。点对点模式特点：每个消息只有一个接收者（Consumer）(即一旦被消费，消息就不再在消息队列中)。发送者和接收者间没有依赖性，发送者发送消息之后，不管有没有接收者在运行，都不会影响到发送者下次发送消息；接收者在成功接收消息之后需向队列应答成功，以便消息队列删除当前接收的消息；发布订阅模式发布/订阅模式特点：每个消息可以有多个订阅者；发布者和订阅者之间

一、可视化工具https://pan.baidu.com/s/1qYifoa4密码：el4o下载解压之后，编辑该文件，修改zookeeper地址，也就是kafka注册的zookeeper的地址，如果是zookeeper集群，以逗号分开viconf/application.conf启动命令bin/kafka-manager默认9000端口，直接访问，添加一个名字，名字只是方便开发者使用，随便起，地址是zookeeper的地址和端口点进去可以看到对应的主体以及kafka的集群节点信息二、线上环境规划JVM参数设置kafka是scala语言开发，运行在JVM上，需要对JVM参数合理设置，参看JVM调

        kafka是一种分布式的，基于发布/订阅的消息系统。它可以处理消费者在网站中的所有动作流数据。这种动作(网页浏览，搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。一、kafka概念        kafka是一个消息系统，用作LinkedIn的活动流（ActivityStream）和运营数据处理管道（Pipeline）的基础。活动流数据是几乎所有站点在对其网站使用情况做报表时都要用到的数据中最常规的部分。活动数据包括页面访问量（PageView）、被查看内容方面的信息以及搜索情况等内容。这种数据通常

Kafka系列之：UnexpectedhandshakerequestwithclientmechanismPLAIN,enabledmechanismsare[]一、完整报错二、错误原因三、解决方法一、完整报错java.util.concurrent.ExecutionException:org.apache.kafka.common.errors.IllegalSaslStateException:UnexpectedhandshakerequestwithclientmechanismPLAIN,enabledmechanismsare[]atorg.apache.kafka.commo

事件起因今天跑了一下kafka的示例demo，突然意识到一个问题。消费者拉取broker的消息时需要指定groupid，而生产者将消息发送到broker的时候并不会指定groupid，那么消费者的groupid从哪里获取呢？查询查阅我的这篇文章 kafka消费者 的3.1小节，如果不配置该参数，则会抛出异常。为此，笔者验证了一下： 解决方案去Kafka目录下的config目录，找到consumer.properties打开该配置文件，赫然发现groupid这个配置项。 

记录：460场景：在SpringBoot微服务集成Kafka客户端kafka-clients-3.0.0操作Kafka的Topic的创建和删除。版本：JDK1.8,Spring Boot2.6.3,kafka_2.12-2.8.0,kafka-clients-3.0.0。Kafka安装：https://blog.csdn.net/zhangbeizhen18/article/details/1290713951.微服务中配置Kafka信息1.1在pom.xml添加依赖pom.xml文件：org.apache.kafkakafka-clients3.0.0解析：使用原生的kafka-client

前言Kafka是一种流处理平台，用于在分布式系统中处理高吞吐量的数据流。它是一种基于发布订阅模式的消息系统，能够处理来自多个应用程序的数据流。Kafka具有高度的可扩展性、可靠性和性能，使得它成为处理大数据的流行选择。SpringBoot是一种开源框架，用于简化Java应用程序的开发过程。它提供了一种快速、灵活且生产就绪的方法来构建Java应用程序。SpringBoot可以轻松地创建可部署的独立应用程序，并且可以轻松地将这些应用程序部署到云环境中。提示：在本文中，我们将介绍如何使用SpringBoot整合Kafka。我们将演示如何配置和使用SpringBoot和Kafka来实现高效的消息传递。

目录标题一、异步发送二、同步发送三、回调异步发送Kafka是一种分布式流处理平台，它是一种高吞吐量、可扩展、可持久化的消息队列系统，用于处理和存储实时流式数据。Kafka基于发布-订阅模式，采用了分布式、多副本、分区的架构。它允许生产者将数据以消息的形式发送到Kafka集群的一个或多个主题(topic)中，而消费者可以从这些主题中订阅并获取数据。每个主题可以被分为多个分区(partition)，每个分区可以在多个服务器上进行副本(replica)以实现高可用性和容错性。Kafka具有以下几个主要特点：高吞吐量：Kafka采用了顺序磁盘写入和批量发送等优化策略，能够支持大规模数据的高吞吐量处理。

文章目录前言一、安装配置kafka1.下载2.配置log路径3.启动二、spring整合1.导入依赖2.yml配置3.测试生产者消费者测试方法结果前言kafka是一个分布式的基于发布订阅模式的消息队列。一、安装配置kafka1.下载官网：https://kafka.apache.org/downloads选择Binarydownloads下载，该下载的只需解压就可以用，Sourcedownload需要安装后使用。2.配置log路径在安装好的kafka文件里打开config里面的server,properties手动创建一个log目录并把路径写进去。3.启动在kafka目录下运行cmd并输入如下

kafka删除topic消息的三种方式方法一：快速配置删除法（确保topic数据不要了）1.kafka启动之前，在server.properties配置delete.topic.enable=true2.执行命令bin/kafka-topics.sh--delete--topictest--zookeeperzk:2181或者使用kafka-manager集群管理工具删除注意：如果kafka启动之前没有配置delete.topic.enable=true，topic只会标记为markedfordeletion，加上配置，重启kafka，之前的topick就真正删除了。方法二：设置删除策略（确保