手把手教你搭建zookeeper和kafka集群（超级详细）
手把手教你搭建zookeeper和kafka集群（超级详细）
Flink 从 kafka 中读取数据并输出到 kafka
Flink 从 kafka 中读取数据并输出到 kafka。FlinkKafkaConsumer（）和FlinkKafkaProducer （）介绍
【大数据技术】Spark+Flume+Kafka实现商品实时交易数据统计分析实战（附源码）
【大数据技术】Spark+Flume+Kafka实现商品实时交易数据统计分析实战（附源码）
Kafka的安装和使用（Windows中）
2.3.1.2在小黑窗3中输入.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic_test001然后回车。在黑窗口
Kafka 入门篇（一）
初识 Kafka什么是 KafkaKafka 的基本术语Kafka 的特性（设计原则）Kafka 的使用场景Kafka 的消息队列点对点模式的消息队列发布-订阅模式的消息队列Kafka 系统架构核心 APIKafka 为何如此之快broker 端配置broker.idportzookeeper.co
FlinkSQL消费Kafka写入Hive表
flinkSQL消费kafka实时写入hive表
Kafka的命令行操作
每个分区多个副本的主节点编号，这个在集群中才会是其它值，这里是单机模式，值等于唯一副本编号。执行此命令后，再来新的数据，也会被继续消费，就和普通的消费者一样。如果想要读取历史数据，可以选择把主题中的数据全部读取出来。就是在刚才的光标下继续输入一个数据，再回车即可。：分区编号是0，代表只有一个分区，编
logstash配置kafka输入 无法获取kafka数据 报错
logstash 配置kafka 接入kafka 认证
kafka时间戳的详解及使用
Kafka从0.10.0.0版本起，在消息内新增加了个timestamp字段，在Kafka 0.10.1.0以前(不包含0.10.1.0)，对于一个Topic而言，其Log Segment是由一个.log文档和一个.index文档组合而成，分别用来存储具体的消息数据和对应的偏移量。
Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)
Windows下安装使用Kafka(使用Kafka内置的ZooKeeper)
Flink sql 写ddl连接kafka
flink sql 连接kafka 的DDL语句和提交java.lang.NoClassDefFoundError: org/apache/kafka/clients/consumer/OffsetResetStrategy Recovery is suppressed by NoRestartBa
二、使用java简单操作kafka
springboot整合kafka，java简单操作kafka
Kafka 动态配置
动态配置 : 修改参数后，无需重启 Broker 就能生效。
Kafka版本滚动升级（不停机）
升级Kafka集群的版本其实很简单，核心步骤只需要4步，但是我们需要在升级的过程中确保每一步操作都不会“打扰”到producer和consumer的正常运转。注意：替换新版broker后，注意查看新版broker是否已经注册到zookeeper，所在机器上的的副本是否已经可用。注意：启动3.4.0的
kafka查询offset&生产者offset计算&消费offset计算
对kafka做监控，需要获取到kafka接收到消息的offset和被消费者消费掉消息的offset，编写接口将数值交给prometheus，直接观察判断kafka的消费性能如何。
Kafka可视化工具-Offset Explorer使用
一、概述Offset Explorer（以前称为Kafka Tool）是一个用于管理和使Apache Kafka ®集群的GUI应用程序。它提供了一个直观的UI，允许人们快速查看Kafka集群中的对象以及存储在集群主题中的消息。它包含面向开发人员和管理员的功能。二、环境信息系统环境：windows
Kafka入门（七）
下面聊聊Kafka的配置参数，包括生产者的配置参数、Broker的配置参数、消费者的配置参数。
Kafka系列：查看Topic列表、消息消费情况、模拟生产者消费者
这条命令其实并不执行删除动作，仅仅是在zookeeper上标记该topic要被删除而已，同时也提醒用户一定要提前打开delete.topic.enable开关，否则删除动作是不会执行的。a）在server.properties中设置delete.topic.enable参数为ture。3.执行删除命
探究：kafka生产者/消费者与多线程安全
Kafka生产者是线程安全的，可以在多个线程中共享一个Kafka生产者实例。这是因为Kafka生产者实例内部使用了一些同步机制来保证线程安全，例如使用了线程安全的队列来缓存消息，使用了同步锁来保护共享资源的访问等。同时，Kafka生产者的send()方法是非阻塞的，可以在多个线程中并发调用，不会阻塞
Springboot集成kafka(环境搭建+演示)|超级详细，建议收藏
上一期，我是带着大家入门了SpringBoot整合WebSocket，今天我再来一期kafka的零基础教学吧。不知道大家对kafka有多少了解，反正我就是从搭建开始，然后再加一个简单演示，这就算是带着大家了个门哈，剩下的我再后边慢慢出教程给大家说。/**log . info("topic.group
