个人技术分享

发布与订阅系统：数据的发送者不会直接把消息发送给接收者；发布者以某种方式对消息进行分类，接收者通过订阅他们来接收特定类型的消息。发布与订阅系统也是事件驱动型程序的关键组件。

本文介绍了如何使用Java编写Kafka的生产者和消费者示例。通过这些示例代码，我们可以轻松地在Java应用中集成Kafka，实现消息的生产和消费。Kafka具有高性能、高可靠性的特点，适用于各种场景的消息处理需求。

启动kafka后报错：org.apache.kafka.common.KafkaException: Socket server failed to bind to 127.0.0.1:9092: 无法指定被请求的地址。2、在listeners = PLAINTEXT://your.host.name:9092下方添加服务器内外网地址配置信息。advertised.listeners=PLAINTEXT://外网IP:9092。listeners=PLAINTEXT://内外IP:9092。

本文介绍如何通过观测云的采集器 Datakit 采集 Kafka 中的业务日志。

安装Kafka -> 启动Kafka -> 测试Kafka是否正常工作

但随着 Kafka 的发展，尤其是从 Kafka 2.8 版本开始，引入了 Kafka Raft 协议（也称为 KRaft 模式），这是一个重大的架构变革，它允许 Kafka 在没有依赖外部 ZooKeeper 的情况下运行。： 在生产环境中，Kafka 和 Zookeeper 会部署在不同的服务器上，形成真正的分布式集群。运行控制台生成器客户端，在主题中写入一些事件。：当消费者群组的成员发生变化（例如消费者加入或离开群组）时，Kafka会触发再均衡过程，重新分配分区给群组中的消费者，确保消息的公平消费。

主要用于复习和知识点快速复习。