kafka
-
Kafka如何配置内外网多ip访问
近日在云虚拟机上搭建kafka测试集群（kafka版本2.8.2），由于云虚拟机只配置了内网网卡，在配置kafka的config/server.properties时，将liste…
-
kafka如何实现延迟队列来实现延迟消费
在Kafka中实现延迟队列来实现延迟消费的最有效率的方式是使用Kafka的时间戳和时间戳索引功能。 以下是使用Java实现Kafka延迟队列的详细步骤： 创建一个专门用于延迟消费的…
-
Kafka安全性配置最佳实践
Kafka安全性配置最佳实践 一、Kafka 安全性配置 1. 安全配置的必要性 提高 Kafka 系统的可靠性 添加认证配置 代码示例： 添加 SSL 配置 代码示例： 二、安全…
-
元数据管理-Atlas的介绍和使用(集成Hive、Solr、Kafka、Kerberos)
概述 文章目录 概述 介绍 架构发展 架构原理 类型系统介绍 类型 hive_table类型介绍 DataSet类型定义 Asset类型定义 Referenceable类型定义 P…
-
springboot kafka消息消费学习 @KafkaListener 使用
kafka 配置类 用途：定义使用的基本 kafka 配置，以及定义Bean 下面文件是读取本地 spring 的标准配置文件的类，用于一般属性获取等操作 import lombo…
-
【Kafka系列 03】生产级集群参数配置
1. 概述 本文将从 Bocker 端参数、Topic 级别参数、JVM 端参数、操作系统级别参数分别介绍 Kafka 集群参数应该怎么配置。文中提到的这些参数都很重要，请读者仔细…
-
【运维知识大神篇】超详细的ELFK日志分析教程10（kafka集群原理+基本使用+zookeeper和kafka堆内存调优+kafka监控和压力测试+filebeat和logstash对接kafka）
本篇文章继续给大家介绍ELFK日志分析，我们先前介绍了ELFK架构，zookeeper部署使用，kafka的部署，仅差kafka使用就将整个体系融汇贯通了。我们本篇文章将以kafk…
-
depends
如果你经常使用docker-compose启动服务的话，可能会遇到下面的问题：服务 B 依赖服务 A，需要服务 A 先启动，再启动服务 B 举个例子，在部署 kafka 集群的时候…
-
如何删除kafka消费组
如何删除Kafka消费组 Kafka消费组可以通过Kafka客户端的命令行方式连接Kafka实例完成删除。 查询消费组 kafka-consumer-groups.sh ̵…
-
20道常见的kafka面试题以及答案
JAVA面试宝典，搞定JAVA面试，不再是难题，系列文章传送地址，请点击本链接。 目录 1、kafka的消费者是pull(拉)还是push(推)模式，这种模式有什么好处？ 2、ka…
-
Kafka-Java四：Spring配置Kafka消费者提交Offset的策略
一、Kafka消费者提交Offset的策略 Kafka消费者提交Offset的策略有 自动提交Offset： 消费者将消息拉取下来以后未被消费者消费前，直接自动提交offset。 …
-
CDH大数据平台 16Cloudera Manager Console之Sentry权限配置和测试(markdown新版)
?个人主页：@与自己作战 ?作者简介：大数据领域优质创作者、CSDN@内容合伙人、阿里云专家博主 ?希望大佬们多多支持，携手共进 ? 如果文章对你有帮助的话，欢迎评论?点赞?收藏?…
-
使用Flink处理Kafka中的数据
目录 使用Flink处理Kafka中的数据 前提： 一， 使用Flink消费Kafka中ProduceRecord主题的数据 具体代码为（scala） 执行结果 …
-
kafka详解一
kafka详解一 1、消息引擎背景 根据维基百科的定义，消息引擎系统是一组规范。企业利用这组规范在不同系统之间传递语义准确的消息，实现松耦合的异步式数据传递. 即：系统 A 发送消…
-
Spring-Kafka如何实现批量消费消息并且不丢失数据
Spring-Kafka如何实现批量消费消息并且不丢失数据 先给答案： // 批量消费配置: 1批量, 2手动提交 factory.setBatchListener(true); …
