zookeeper+kafka
主要原因是由于在高并发环境下，同步请求来不及处理，请求往往会发生阻塞。比如大量的请求并发访问数据库，导致行锁表锁，最后请求线程会堆积过多，从而触发 too many connection 错误，引发雪崩效应。我们使用消息队列，通过异步处理请求，从而缓解系统的压力。消息队列常应用于异步处理，流量削峰，
zookeeper+kafka分布式消息队列集群的部署
Zookeeper是一个开源的分布式的，为分布式框架提供协调服务的Apache项目。主要原因是由于在高并发环境下，同步请求来不及处理，请求往往会发生阻塞。比如大量的请求并发访问数据库，导致行锁表锁，最后请求线程会堆积过多，从而触发 too many connection 错误，引发雪崩效应。我们使用
Kafka与Zookeeper版本对应关系
其中2.11表示的是Scala的版本，因为Kafka服务器端代码完全由Scala语音编写。”-“后面的1.1.1表示的kafka的版本信息。遵循一个基本原则，Kafka客户端版本和服务端版本应该保持一致，否则可能会遇到一些问题。可以根据源码包或者安装包来确认对应的zookeeper版本是哪个。支持的
Kafka-消费者组消费流程
消费者向kafka集群发送消费请求，消费者客户端默认每次从kafka集群拉取50M数据，放到缓冲队列中，消费者从缓冲队列中每次拉取500条数据进行消费。
使用flink的sql-client.sh，测试mysql--＞kafka--＞kafka--＞mysql实时流
使用flink的sql-client测试数据流程mysql-->kafka-->kafka-->mysql
kafka（一）
kafka集群包括一个或者多个服务器，服务器的节点叫做broker。
SpringBoot集成Kafka版本不兼容导致出现错误
SpringBoot集成Kafka版本不兼容导致出现错误
【大数据工具】Kafka伪分布式、分布式安装和Kafka-manager工具安装与使用
管理多个 Kafka 集群便捷的检查 Kafka 集群状态（topic，broker，备份分布情况，分区分布情况）选择要运行的副本基于当前分区状况进行可以选择 topic 配置并创建 topic（0.8.1.1 和 0.8.2 的配置不同）删除 topic（只支持 0.8.2 以上的版本并且要在 b
kafka-2.12使用记录
kafka-ui-lite是一个开源的kafka监控项目，可以在gitee下载.提供了对kafka 、zookeeper 、redis的监控和管理功能，支持在线浏览和管理kafka的 topic主题/kafka集群/group分组支持在线发送kafka消息。
Kafka：什么是kafka？ ①
kafka是一种分布式的，基于发布/订阅的消息系统。它可以处理消费者在网站中的所有动作流数据。这种动作(网页浏览，搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。
kafka常用命令
bin/kafka-consumer-groups.sh --bootstrap-server $nodes --group $groupname --reset-offsets --all-topics --to-earliest --execute # 重设消费者组位移(待验证)bin/kafk
kafka实现消息接受和发送
kafka实现消息接受和发送
kafka 安装快速入门
1、service.properties (添加)进入到config文件夹里面，找到zookeeper.properties文件，进行编辑，找到。kafka 集成了 zookeeper 的软件包，不需要安装，配置就好。直接上干货，我们公司最近要进行消息推送指定软件kafka,直接走起。完成启动就可以
分布式 - 消息队列Kafka：Kafka 消费者消息消费与参数配置
01. 创建消费者在读取消息之前，需要先创建一个KafkaConsumer对象。创建KafkaConsumer对象与创建KafkaProducer对象非常相似——把想要传给消费者的属性放在Properties对象里。为简单起见，这里只提供4个必要的属性：bootstrap.servers、key.d
kafka常用命令
【代码】kafka常用命令。
你在项目中是如何使用kafka的？
较少的分区数可能会限制并行性能，而较多的分区数可能会增加系统管理的复杂性。较少的分区数可能会导致消息处理能力不足，而较多的分区数则会增加系统的管理复杂性。通过合理设置分区数、优化生产者端性能和进行消费者组管理，可以充分发挥Kafka的优势，并构建可靠的消息传递系统。另一方面，如果订单数据的有序性对业
Kafka入门到精通
buffer.memory它代表缓冲区内存的大小，默认为32M，batch.size代表消息批次的大小，默认为16kb，在BufferPool中，batch.size其实就是代表一个ByteBuffer的大小，因为BufferPool只管理batch.size大小的ByteBuffer，在kafka
大数据-玩转数据-FLINK-从kafka消费数据
运行本段代码，等待kafka产生数据进行消费。
【Kafka】Kafka consumer lag 为负数
最近对Kafka 集群部署了监控，并集成了granfana图标展示。发现有时候为负数。于是进行一番查询，并总结整理下。
Kafka消息监控管理工具Offset Explorer的使用教程
Offset Explorer是一款用于监控和管理Apache Kafka集群中消费者组偏移量的开源工具。它提供了一个简单直观的用户界面，用于查看和管理Kafka消费者组偏移量的详细信息。
