搜索[kafka操作]结果-低调大师优秀个人博客

精选列表

搜索[kafka操作]，共10023篇文章

CentOS7设置SWAP分区，小内存服务器的救世主

那些被释放的空间可能来自一些很长时间没有什么操作的程序，这些被释放的空间被临时保存到Swap分区中，等到那些程序要运行时，再从Swap分区中恢复保存的数据到内存中。

2025-09-05

Docker安装Oracle12C，快速搭建Oracle学习环境

安装说明 1.操作系统CentOS7_x64 2.安装的数据库为Oracle12C 3.已经安装了Docker环境 4.需要检查是否有swap分区，如果没有请设置安装 1.Docker安装镜像准备

2025-09-05

基于ranger的kafka权限控制

上一篇文章讲到了kafka中的ACL，也提到了是以插件式的形式实现的，本文就来聊聊基于ranger的kafka访问控制。

2022-08-15

一文详解Kafka API

摘要：Kafka的API有Producer API，Consumer API还有自定义Interceptor (自定义拦截器)，以及处理的流使用的Streams API和构建连接器的Kafka Connect

2022-02-11

Kafka分区分配策略详解

在上一篇文章中，我们为大家详细介绍可Kafka的原理与核心概念，包括控制器选举及恢复、分区leader的选举等，详情可见 Kafka核心技术概念与架构原理，本次我们来为大家详细讲解Kafka等分区分配策略

2022-01-24

kafka connector 监听sqlserver 新手尝试

,confluent,kafka.

2020-10-27

保护Kafka环境的最佳实践

Kafka Broker可以同时启用多种机制，然后客户端可以选择用于身份验证的机制。Kafka监听器大致是Broker接受连接的IP、端口和安全协议。

2020-06-12

消费语义at most once：最多消费一次，消息可能会丢失-------log日志at least once：至少消费一次，但是会重复消费例如手动异步提交offsetexactly once：正好一次，不丢失，不重复 0.10.0.1不支持，官方说0.11已支持例子1.log日志允许丢失使用第一种2.log日志算钱的不允许丢，使用第二种+去重+redis部分公司去重方法，对每一条日志取一个hash值，存放到redis里面，如果redis里面有了，就不放到下游去处理3.mysql sql语句入库选择第二种并使用hbase的put保证去重复。insert into。。。1；insert into。。。2；insert into。。。3；

2020-05-25

Kafka及周边深度了解

的大体简介到Kafka的周边产品比较，再到Kafka与Zookeeper的关系，进一步理解Kafka的特性，包括Kafka的分区和副本以及消费组的特点及应用场景简介。

2019-12-08

Kafka再平衡机制详解

所谓的再平衡，指的是在kafka consumer所订阅的topic发生变化时发生的一种分区重分配机制。

2019-10-15

Docker如何搭建Zookeeper、Kafka集群？

: broker1 KAFKA_ADVERTISED_PORT: 9092 KAFKA_ZOOKEEPER_CONNECT: zoo1:2181/kafka1,zoo2:2181/kafka1,zoo3

2019-08-27

Spark Streaming应该如何消费Kafka？

本文首先对spark streaming嵌入kafka的方式进行归纳总结，之后简单阐述Spark streaming+kafka在舆情项目中的应用，最后将自己在Spark Streaming+kafka

2019-07-19

spring-cloud-stream整合kafka

;groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream-binder-kafka

2019-06-17

Kafka数据迁移MaxCompute最佳实践

前提条件搭建Kafka集群进行数据迁移前，您需要保证自己的Kafka集群环境正常。本文使用阿里云EMR服务自动化搭建Kafka集群，详细过程请参见：Kafka 快速入门。

2019-05-28

分布式消息队列kafka

kafka是Linkedin开源的分布式发布-订阅消息系统（消息队列） kafka特点 1 高吞吐率、低延迟，每秒处理几十万消息，延迟最低几毫秒 2 可扩展性，支持动态扩展节点数据 3 持久性与可靠性，

2019-03-11

创建消息队列（Kafka）源表

本页目录 WITH参数 kafka版本对应关系 Kafka消息解析自建kafka WITH参数 Kafka源表的实现来源于自社区的kafka版本实现。注意：本文档只适合独享模式下使用。

2018-11-13

kafka原理及Docker环境部署

实时高效处理流式数据：kafka每秒可以处理几十万条消息，它的延迟最低只有几毫秒，每个topic可以分多个partition, consumer group 对partition进行consume操作。

2018-10-25

Kafka常用命令收录

2.Broker默认端口号 9092，建议安装时，在zookeeper中指定kafka的根目录，比如“/kafka”，而不是直接使用“/”，这样多套kafka也可共享同一个zookeeper集群。

2018-09-08

玩转Kafka的生产者

上篇文章学习kafka的基本安装和基础概念，本文主要是学习kafka的常用API。其中包括生产者和消费者，多线程生产者，多线程消费者，自定义分区等，当然还包括一些避坑指南。

2018-08-02

一文看懂 kafka 机制

操作。

2018-07-08

rocketMq和kafka的架构区别

这篇博文主要讲清楚kafka和rocketMq的两个不同点，1、rocketMq的namesvr和kafka的zookeeper对比；2、kafka为什么比rocketMq有更大的吞吐量。

2018-04-16

kafka + jstorm版本升级安装（三）

_2.9.2-0.8.1 --->>> kafka_2.9.2-0.8.2.2 发行日志：https://archive.apache.org/dist/kafka/0.8.2.2/

2017-11-21

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。