kafka实战
kafka目录简介 使用场景安装并运行核心概念 Topics和Logs生产者消费者broker分区(partition)和副本(replication)Kafka的保证 数据可靠性保证数据一致性保证配置 Broker配置Topic配置Producer配置Consumer配置常见操作 创建和删除topic修改topicleader 平衡检查消费者位置demo 源码下载简介Kafka...
2024-01-10
kafka安装
1、下载解压https://mirror.bit.edu.cn/apache/kafka/2.5.0/kafka_2.12-2.5.0.tgz解压：> tar -xzf kafka_2.12-2.5.0.tgz> cd kafka_2.12-2.5.02、 启动ZooKeeper服务器。因为Kafka 使用了 ZooKeeper，所以需要先启动一个ZooKeeper服务器。 可以单独下载zookeeper安装启动，也可以通过与kafka打包在一起的便捷脚本来快速简单地创建一个单节点Zo...
2024-01-10
Kafka原理和实战
本文首发于 vivo互联网技术 微信公众号 https://mp.weixin.qq.com/s/bV8AhqAjQp4a_iXRfobkCQ作者简介：郑志彬，毕业于华南理工大学计算机科学与技术（双语班）。先后从事过电子商务、开放平台、移动浏览器、推荐广告和大数据、人工智能等相关开发和架构。目前在vivo智能平台中心从事 AI中台建设以及广告推荐...
2024-01-10
深入解析kafka 架构原理
kafka 架构原理大数据时代来临，如果你还不知道Kafka那就真的out了！据统计，有三分之一的世界财富500强企业正在使用Kafka，包括所有TOP10旅游公司，7家TOP10银行，8家TOP10保险公司，9家TOP10电信公司等等。LinkedIn、Microsoft和Netflix每天都用Kafka处理万亿级的信息。本文就让我们一起来大白话kafka的架构原...
2024-01-10
kafka随机写
设计目标时间复杂度O(1)的方式提供消息持久化能力的。即使TB级别以上数据也能保证常数时间的访问性能，单机支持每秒100K条消息的传输。特点：高吞吐量。消息持久化。分布式。消费消息采用Pull模式。支持Online和Offine场景，同时支持离线数据处理和实时数据处理。Kafka的基本存储单元是...
2024-01-10
kafka创建命令
kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 3 --partitions 3 --topic topic1 --zookeeper zookeeper地址 --create 创建 --replication-factor 每个分区的副本数量 --partitions 分区数量 --topic topic名字 2.删除 kafka-topics.sh --zookeeper localhost:21...
2024-01-10
kafka集群的安装
1.1 首先kafka是一个分布式的流平台。 1.1.1 像消息队列或者企业消息队列一样发布和订阅 record。 1.1.2 能够存储stream并且具有容错能力 1.1.3 在流产生时能对流进行加工 (process) .kafka 的两大应用场景 1 两个系统或者应用程序间交换数据( 介绍 1.1 首先kafka是一个...
2024-01-10
【Java】kafka技术原理解析
前言：有好多同学留言说看不懂我之前写的博客——kafka应用实例篇，不明白里面的代码为什么那么写，我找到了自己之前写的关于kafka技术解析的ppt，现将部分重点及相关原理整理出来供大家参考。1. 消息队列介绍kafka定义：kafka是一个分布式的基于发布/订阅模式的消息队列（message queue），主要应用...
2024-01-10
PHP处理kafka消息队列
安装PHP—kafka扩展后，就可以开始编写 php 消费消息的脚本了，php-rdkafka 扩展提供了几种消息处理的方式低级方式（Low level）这种方式没有消费组的概念<?php$rk = new RdKafkaConsumer();$rk->setLogLevel(LOG_DEBUG);// 指定 broker 地址,多个地址用"," 分割$rk->addBrokers("192.168.33.1:9092");$topic = $rk->newTopic("test");$topic->c...
2024-01-10
Kafka案例
假设我们正在开发一个多人在线网络游戏。游戏中，玩家需要在虚拟世界中进行合作或者展开竞争。玩家之间也常常存在各种交易，包括钱、道具等。因此游戏开发人员必须保证玩家没有作弊，规则如下：如果玩家交易额显著高于正常水平或者玩家登录的IP地址与之前20次登录的不一样，那么交易将...
2024-01-10
Kafka简介
KafkaKafka是最初由Linkedin公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于zookeeper协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于hadoop的批处理系统、低延迟的实时系统、storm/Spark流式处理引擎，web/nginx日志、访问日志，...
2024-01-10
Kafka介绍
Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统。Kafka具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。一般在企业架构设计中起到解耦、削峰、异步处理的作用。2 ...
2024-01-10
Apache kafka 工作原理介绍
原文：https://developer.ibm.com/zh/articles/os-cn-kafka/消息队列消息队列技术是分布式应用间交换信息的一种技术。消息队列可驻留在内存或磁盘上, 队列存储消息直到它们被应用程序读走。通过消息队列，应用程序可独立地执行–它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序接收此消息。...
2024-01-10
kafka消费者偏移量提交
同步提交当前偏移量把auto.commit.offset设为false,方应用程序决定何时提交偏移量,使用commitSync()方法提交偏移量最简单可靠,这个api会提交poll()方法返回的最新偏移量,提交成功后马上返回,如果提交失败,则跑出异常注意: commitSync()方法提交的偏移量是最新的偏移量,需要在处理完所有消息之后再调用代...
2024-01-10
Java中Lock原理探究
本教程操作环境：windows7系统、java10版，DELL G3电脑。1.ReentrantLock的调用过程 /** * Creates an instance of {@code ReentrantLock}. * This is equivalent to using {@code ReentrantLock(false)}. */ public ReentrantLock() { sync = new NonfairSync(); }经过观察Re...
2024-01-10
kafka生产实践(详解)
1.引言最近接触到一个APP流量分析的项目，类似于友盟。涉及到几个C端（客户端）高并发的接口，这几个接口主要用于C端数据的提交。在没有任何缓冲的情况下，一个接口涉及到5张表的提交。压测的结果很不理想，主要瓶颈就在与RDS的交互。一台双核，16G机子，单实例，jdbc最大连接数100，吞吐量竟...
2024-01-10
kafka核心原理的秘密，藏在这16张图里
Kafka 是一个优秀的分布式消息中间件，许多系统中都会使用到 Kafka 来做消息通信。对分布式消息系统的了解和使用几乎成为一个后台开发人员必备的技能。今天码哥字节就从常见的 Kafka 面试题入手，和大家聊聊 Kafka 的那些事儿。讲一讲分布式消息中间件问题什么是分布式消息中间件？消息中间件...
2024-01-10
Kafka的知识点
KafkaBorker1.kafka服务节点，一般使用奇数个数，配合zk做高可用。2.broker存放消息，磁盘存储，使用分区+顺序寻址+零拷贝，实现快速存储。3.topic ->partition ->segement=.index+.log；其中index存储索引文件，log存储具体消息。当通过offset查询message的时候，首先通过二分法找到具体的.index，然后顺序查找找到具...
2024-01-10
kafka-可靠的数据传递
可靠性保证了解系统的保证机制对于构建可靠的应用程序来说至关重要，这也是能够在不同条件下解释系统行为的前提。kafka做出了以下保证kafka可以保证分区消息的顺序。如果使用同一个生产者往同一个分区写入消息，而且消息B在消息A之后写入，那么kafka可以保证消息B的偏移量比消息A的偏移量大（...
2024-01-10
3台虚拟机搭建kafka集群
1.下载wget http://mirror.bit.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz 2.解压tar -zxvf kafka_2.13-2.5.0.tgz -C /usr/local 3.改名mv kafka_2.13-2.5.0 kafka 4.修改server.propertiesvim /usr/local/kafka/config/server.properties 5.发送到ht-2和ht-3节点scp -r kafka ht-2:/u...
2024-01-10
一次kafka消息堆积问题排查
收到某业务组的小伙伴发来的反馈，具体问题如下：项目中某 kafka 消息组消费特别慢，有时候在 kafka-manager 控制台看到有些消费者已被踢出消费组。从服务端日志看到如下信息：该消费组在短时间内重平衡了 600 多次。从 cat 查看得知，每条消息处理都会有 4 次数据库的交互，经过一番沟通之后，发...
2024-01-10
【Java】kafka的基本概念
一、基本概念1、brokerbroker 指的一个kafka服务器，一个kafka集群是由多个 kafka broker 组成。2、producerproducer 指的是消息生产者，即发送消息到 kafka broker 的客户端。3、consumerconsumer 指的消息消费者，即从 kafka broker 获取消息的客户端。4、cousumer groupconsumer group 指的是消费者组，拥有相同的 group id 的消...
2024-01-10
分布式专题｜最近一直死磕kafka设计原理，都肝吐了
点击上方蓝字关注我们 文末有惊喜kafka架构图 在这里插入图片描述 kafka核心控制器定义在kafka集群中，会选举出一个broker作为控制器(controller)，负责管理集群中所有的分区和副本的状态；职责 监听broker变化，通过监听Zookeeper中的/brokers/ids/ 节点方式来实现 监听topic变化...
2024-01-10
kudu记录kudu原理
1.kudu是什么？2.kudu基本概念特点： High availability（高可用性）。Tablet server 和 Master 使用 Raft Consensus Algorithm 来保证节点的高可用，确保只要有一半以上的副本可用，该 tablet 便可用于读写。例如，如果3个副本中有2个或5个副本中的3个可用，则该tablet可用。即使在 leader tablet 出现故障的情况下，读...
2024-01-10
Kafka及周边深度了解
本文属于原创，转载注明出处，欢迎关注微信小程序小白AI博客 微信公众号小白AI或者网站 https://xiaobaiai.net 或者我的CSDN http://blog.csdn.net/freeape[TOC]0 前言文章有点长，但是写的都挺直白的，慢慢看下来还是比较容易看懂，从Kafka的大体简介到Kafka的周边产品比较，再到Kafka与Zookeeper的关系，进一步理解K...
2024-01-10
