kafka
-
Spark写入kafka（批数据和流式）
Spark写入（批数据和流式处理） Spark写入kafka批处理 写入kafka基础 # spark写入数据到kafka from pyspark.sql import Spar…
-
kafka max.poll.records用法介绍
一、max.poll.records是什么 max.poll.records是Kafka consumer的一个配置参数，表示consumer一次从Kafka broker中拉取的…
-
Kafka的@KafkaListener注解参数详解
@KafkaListener 注解提供了许多可配置的参数，以便更灵活地定制 Kafka 消息监听器的行为。 topics： 描述： 指定监听的 Kafka 主题，可以是一个字符串数…
-
MQ回顾之kafka速通
不定期更新 官网概念自查 官网：Apache Kafka kafka结构 和kafka相关的关键名词有：Producer、Broker、Topic、Partition、Replic…
-
Kafka收发消息核心参数详解
这一部分主要是从客户端使用的角度来理解Kakfa的重要机制。重点依然是要建立自己脑海中的Kafka消费模型。Kafka的HighLevel API使用是非常简单的，所以梳理模型时也…
-
Windows下安装单机Kafka环境及配置SASL身份认证
0 安装JDK zookeeper和kafka都是java开发的，所以安装前先安装1.8版本以上的jdk，并设置环境变量 JAVA_HOME=d:\env\Java\jdk1.8….
-
SpringBoot 集成 Kafka 高级实现
1、简介 之前博客中记录了直接使用Kafka客户端实现生产者和消费者之间的交互，这种方式通过设置各种参数编码繁琐，因此通过SpringBoot集成Kafka成为一种…
-
Kafka-副本数量设置
1. ISR副本数量设置 指的是存活的副本数量 ISR 机制的另外一个相关参数是 min.insync.replicas , 可以在 broker 或者主题级别进行配置，代表 IS…
-
踩坑（5）整合kafka 报错 java.net.UnknownHostException: 不知道这样的主机
java.net.UnknownHostException: 不知道这样的主机。 (5c0c3c629db9) at java.base/java.net.Inet6Address…
-
学习笔记 | Kafka
一、概述 定义 1、Kafka传统定义：Kafka 是一个分布式的基于 发布/订阅模式 的消息队列（Message Queue） ，主要应用与大数据实时处理领域。 2、发布/订阅：…
-
Kafka安全认证机制详解之SASL
一、概述 官方文档： https://kafka.apache.org/documentation/#security 在官方文档中，kafka有五种加密认证方式，分别如下： SS…
-
简单实现，在nodejs中简单使用kafka
什么是 Kafka Kafka 是由 Linkedin 公司开发的，它是一个分布式的，支持多分区、多副本，基于 Zookeeper 的分布式消息流平台，它同时也是一款开源的基于发布…
-
13.Spring 整合 Kafka + 发送系统通知 + 显示系统通知
目录 1.Spring 整合 Kafka 2.发送系统通知 2.1 封装事件对象 2.2 开发事件的生产者和消费者 2.3 触发事件：在评论、点赞、关注后通知编辑 3.显示系统…
-
【Kafka面试】Kafka如何保证消息不丢失？
使用Kafka时，在消息的收发过程中都有可能会出现消息丢失。 一、生产者发送消息到broker过程中丢失 1. 设置异步发送 同步发送：会产生阻塞，一般使用异步发送。 异步发送：实…
-
Kafka查看消息是否堆积（服务器）
查询消费组 先进入kafka中的bin目录 ./kafka-consumer-groups.sh –bootstrap-server ip:9092 –li…
