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
Kafka系统整理 一
kafka系统学习
Docker搭建Kafka集群
dokcer搭建kafka集群。
如何确保Kafka消息不丢失
我们知道Kafka对于消息的可靠性可以做到至少一次（at least once）的保证，即消息不会丢失，但有可能重复发送，本文就来分析一下Kafka究竟是如何做到的。可以看出，要想确保Kafka消息不丢失，Consumer、Producer以及Broker都需要做好各自所负责的部分，Producer
大数据面试重点之kafka（三）
大数据面试重点之kafka（三）
Kafka 开启 SASL/PLAINTEXT 认证及 ACL
Linux 安装 Kafka 并开启 SASL/PLAINTEXT 认证
kafka使用时常见的几个错误汇总
kafka常见错误
Monitor 监控架构
采集器: 负责采集监控数据的，采集到数据之后传输给服务端，通常是直接写入时序库对时序库的数据 :- 分析部分: 告警规则判断, 并进行通知- 可视化: 通过各种图表来合理地渲染各类监控数据
logstash-8.2集群部署
logstash集群
kafka如何动态消费新增topic主题
spring-kafka客户端接入新的主题消息，需要硬编码客户端代码，并且重新发布服务，开发成本高操作麻烦。接入kafka-batch-starter组件可以满足动态接入的需求。
【注意】Kafka生产者异步发送消息仍有可能阻塞
Kafka生产者异步发送消息的方法，看似异步，实则可能阻塞。由于发送消息前需要获取元数据Metadata，如果一直获取失败（可能原因包括Broker连接失败、Topic未创建等），将导致长时间阻塞。这点与我们的一般理解不符，需要特别注意。
Windows系统下快速启动Kafka
在Windows系统上启动Kafka服务
Flume学习-采集端口数据存入kafka
Flume学习-采集端口数据存入kafka
Kafka消费者不消费数据
kafka消费者停止消费
kafka实战-消费者offset重置问题
kafka消费者offset重置问题
Kafka和RabbitMQ有哪些区别，各自适合什么场景？
列出业务最重要的几个特点深入到消息队列的细节中去比较等我们对这些中间件的特点非常熟悉之后，甚至可以把业务分解成不同的子业务，再根据不同的子业务的特征，引入不同的消息队列，即消息队列混用。这样，我们就可能会最大化我们的获益，最小化我们的成本。说了这么多，其实还有很多 Kafka 和 RabbitMQ
Kafka在windows下下载、启动、测试详细教程
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic 队列名。kafka-console-consumer.bat --bootstrap-server l
【Kafka】Java实现数据的生产和消费
Kafka 是由Linkedin公司开发的，它是一个分布式的，支持多分区、多副本，基于 Zookeeper 的分布式消息流平台，它同时也是一款开源的。
