哈喽大家好，我是咸鱼最近这段时间比较忙，将近一周没更新文章，再不更新我那为数不多的粉丝量就要库库往下掉了T﹏T刚好最近在学Kafka，于是决定写篇跟Kafka相关的文章（文中有不对的地方欢迎大家指出）考虑到有些小伙伴可能是第一次接触Kafka，所以先简单介绍一下什么是Kafka吧！Kafka介绍Kafka是一个高吞吐的分布式消息系统，不但像传统消息队列（RaabitMQ、RocketMQ等）那样能够【异步处理、流量消峰、服务解耦】还能够把消息持久化到磁盘上，用于批量消费。除此之外由于Kafka被设计成分布式系统，吞吐量和可用性大大提高Kafka角色kafka客户端生产者（producer）：也
文章目录问题描述原因分析Code问题描述报错如下：........Causedby:org.apache.kafka.common.errors.TimeoutException:Expiring1record(s)forart-0:120001mshaspassedsincebatchcreation原因分析这种情况，肯定要先看网络问题嘛首先查看本机防火墙的配置结果都是关闭的（建议开放特定端口）[root@localhostbin]#systemctlstatusfirewalld.service●firewalld.service-firewalld-dynamicfirewalldaem
哈喽大家好，我是咸鱼最近这段时间比较忙，将近一周没更新文章，再不更新我那为数不多的粉丝量就要库库往下掉了T﹏T刚好最近在学Kafka，于是决定写篇跟Kafka相关的文章（文中有不对的地方欢迎大家指出）考虑到有些小伙伴可能是第一次接触Kafka，所以先简单介绍一下什么是Kafka吧！Kafka介绍Kafka是一个高吞吐的分布式消息系统，不但像传统消息队列（RaabitMQ、RocketMQ等）那样能够【异步处理、流量消峰、服务解耦】图片还能够把消息持久化到磁盘上，用于批量消费。除此之外由于Kafka被设计成分布式系统，吞吐量和可用性大大提高Kafka角色kafka客户端生产者（producer）
消息中间件对比：1、吞吐、可靠性、性能Kafka安装Kafka对于zookeeper是强依赖，保存kafka相关的节点数据，所以安装Kafka之前必须先安装zookeeperDocker安装zookeeper下载镜像：dockerpullzookeeper:3.4.14创建容器dockerrun-d--namezookeeper-p2181:2181zookeeper:3.4.14Docker安装kafka下载镜像：dockerpullwurstmeister/kafka:2.12-2.3.1创建容器dockerrun-d--namekafka\--envKAFKA_ADVERTISED_HO
Kafka的消息确认（acknowledgment）机制用于确保生产者发送的消息已经成功被KafkaBroker接收并存储。Kafka提供了三种不同级别的消息确认机制，可以根据需求进行选择：acks=0（不等待确认）：在这种模式下，生产者发送消息后不会等待来自Broker的任何确认。它会立即继续发送下一条消息。这是最低延迟的选项，但也是最不可靠的，因为生产者无法知道消息是否已经成功到达Broker。acks=1（Leader确认）：在这种模式下，生产者发送消息后会等待Broker的领导者（Leader）确认。领导者会确认消息已经被接收，但不一定已经被完全复制到所有的副本。这种模式提供了一定程度
最近在排查一个sparkstreaming在操作kafka时，rebalance触发了一个异常引起任务失败，而组内小伙伴对消费者组的一些基本知识不是很了解，所以抽了些时间进行相关原理的整理。本文就来聊聊相关内容。【消费者组的基本原理】在kafka中，多个消费者可以组成一个消费者组（consumergroup），但是一个消费者只能属于一个消费者组。消费者组保证其订阅的topic的每个分区只能分配给该消费者组中的某一个消费者进行处理，那么这里可能就会出现两种情况：当消费者组中的消费者个数小于订阅的topic的分区数时，那么存在一个消费者到多个分区进行消费的情况；而如果消费者组中的消费者个数大于订阅
目录一、消息和日志的关系二、查看Kafka主题(Topic)情况三、查看Kafka数据存储(Log)情况日志分段存储一、消息和日志的关系可以理解Topic是一个类别的名称，同类消息发送到同一个Topic下面。对于每一个Topic，下面可以有多个分区(Partition)日志文件:Partition是一个有序的message序列(消息队列)，这些message按顺序添加到一个叫做commitlog的文件中。每个partition中的消息都有一个唯一的编号，称之为offset，用来唯一标示某个分区中的message。每个partition，都对应一个commitlog文件。一个partition中
背景算子的联合列表状态是平时使用的比较少的一种状态，本文通过kafka的消费者实现来看一下怎么使用算子列表联合状态算子联合列表状态首先我们看一下算子联合列表状态的在进行故障恢复或者从某个保存点进行扩缩容启动应用时状态的恢复情况算子联合列表状态主要由这两个方法处理：1初始化方法publicfinalvoidinitializeState(FunctionInitializationContextcontext)throwsException{OperatorStateStorestateStore=context.getOperatorStateStore(); //在初始化方法中获取联合列表
Kafka生产者示例：发送JSON数据到KafkaTopicKafka是一个高性能、分布式的流处理平台，广泛应用于大数据领域。本文将深入浅出地介绍如何使用Kafka生产者发送JSON数据到KafkaTopic，并附带相应的源代码。1.准备工作首先，我们需要确保已经安装和配置好了Kafka环境。请根据官方文档进行安装和配置，确保Kafka集群正常运行。2.创建KafkaTopic在开始发送JSON数据前，我们需要先创建一个KafkaTopic，用于接收生产者发送的消息。可以使用以下命令在Kafka集群中创建一个名为"json_topic"的Topic：bin/kafka-topics.sh--c
Zookeeper+kafka的应用及部署一、Zookeeper的概念1、Zookeeper定义2、Zookeeper工作机制3、Zookeeper特点4、Zookeeper数据结构5、Zookeeper应用场景6、Zookeeper选举机制（1）第一次启动选举机制（2）非第一次启动选举机制(1)、当ZooKeeper集群中的一台服务器出现以下两种情况之一时，就会开始进入Leader选举(2)、而当一台机器进入Leader选举流程时，当前集群也可能会处于以下两种状态(3)、集群中确实不存在Leader(4)、选举Leader规则二、部署Zookeeper集群1、安装前准备（1）关闭防火墙（2）
