使用kafka可以对系统解耦、流量削峰、缓冲，可以实现系统间的异步通信等。在活动追踪、消息传递、度量指标、日志记录和流式处理等场景中非常适合使用kafka。这篇...
于是就对streamBridge加了非空判断，不为null时再去调用send方法发送消息，但是仍然遇到了空指针异常。继续debug代码，追踪出错时的情
kafka Consumer分析，速度分析，消息丢失处理
Doris Routine Load正则表达实战Doirs库、表regexp_extractSpark内核和应用实战
flink sql 读取kafka 关联mysql维表 , 写出到pg中 简单演示
优先级消费是业务中经常碰到的场景。对于同一类消息，消息内容可能由于其业务上的属性不同，而具有不同的“重要程度”，比如在一个消息推送系统中，一条告警消息
系统部署教程从0开始做高并发（一）zookeeper集群,kafka，jdk，mysql8.0，redis，mongodb配置
Flink整合kafka实现Flume监控指定文件改动
kafka-console-producer.sh 脚本通过调用 kafka.tools.ConsoleProducer 类加载命令行参数的方式，在控
kafka安装1.下载地址：kafka下载地址zookeeper下载地址（前文有安装教程）2.解压：tar -xvf kafka_2.11-
多分区迁移和单分区一样只是验证和–generate 命令时候输出的、json有一些区别，比单分区会多一些内容。generate模式，给定需要重新分配的
那 Kafka 为什么这么快？如何做到这个高的性能？本篇文章主要从这 3 个角度来分析：生产端、服务端 Broker、消费端
kafka 脚本kafka-configs.sh用法解析
本文总结了 Kafka 体系架构、Kafka 消息发送机制、副本机制，Kafka 控制器、消费端 Rebalance 机制等各方面核心原理，通过本文的
最早是由Linkedin公司开发，后来捐献给了Apack基金会。Kafka被官方定义为分布式流式处理平台，因为具备高吞吐、可持久化、可水平扩展等特性而
== 对于基本类型来说是值比较，对于引用类型来说是比较的是引用；而 equals 默认情况下是引用比较，只是很多类重新了 equals 方法，比如 S
每个 Producer 在初始化的时候都会被分配一个唯一的 PID，对于每个唯一的 PID，Producer 向指定的 Topic 中某个特定的 Pa
