搜索结果
查询Tags标签： topic，共有 206条记录-
95-35-010-Topic-Topic的新建:扩容:删除
文章目录1.视界 1. topic新建 2. Topic扩容 3. Topic 删除3.1 Controller初始化 3.2 init 初始化 3.3 尝试删除 3.4 重启删除3.4.1 onTopicDeletion 3.4.2 completeDeleteTopic1.视界1. topic新建 2. Topic扩容 Kafka 提供了 Topic 扩容工具
2021/8/4 23:09:31 人评论 次浏览 -
95-35-010-Topic-Topic的新建:扩容:删除
文章目录1.视界 1. topic新建 2. Topic扩容 3. Topic 删除3.1 Controller初始化 3.2 init 初始化 3.3 尝试删除 3.4 重启删除3.4.1 onTopicDeletion 3.4.2 completeDeleteTopic1.视界1. topic新建 2. Topic扩容 Kafka 提供了 Topic 扩容工具
2021/8/4 23:09:31 人评论 次浏览 -
confluent-kafka demo
安装：confluent-kafka pip install confluent-kafka 我直接在PyCharm里面安装 启动zk, 启动kafka server 查看已有topic./kafka-topics.sh --zookeeper localhost:2181 --list创建topic testsh kafka-topics.sh --create --zookeeper localhost:2181 --replication-fact…
2021/8/4 6:06:48 人评论 次浏览 -
confluent-kafka demo
安装：confluent-kafka pip install confluent-kafka 我直接在PyCharm里面安装 启动zk, 启动kafka server 查看已有topic./kafka-topics.sh --zookeeper localhost:2181 --list创建topic testsh kafka-topics.sh --create --zookeeper localhost:2181 --replication-fact…
2021/8/4 6:06:48 人评论 次浏览 -
kafka shell简单使用
将kafka添加到环境变量中vim /etc/profile export KAFKA_HOME=/opt/iDataFusion/kafka export PATH=$PATH:$KAFKA_HOME/bin source /etc/profile 创建topic：--create： 指定创建topic动作 --topic：指定新建topic的名称 --zookeeper： 指定kafka连接zk的连接url，该值和…
2021/8/3 7:07:28 人评论 次浏览 -
kafka shell简单使用
将kafka添加到环境变量中vim /etc/profile export KAFKA_HOME=/opt/iDataFusion/kafka export PATH=$PATH:$KAFKA_HOME/bin source /etc/profile 创建topic：--create： 指定创建topic动作 --topic：指定新建topic的名称 --zookeeper： 指定kafka连接zk的连接url，该值和…
2021/8/3 7:07:28 人评论 次浏览 -
Spring Assistant框架搭建消息队列写入Kafka消费Windows单机测试
前提：已安装Java8、Maven 一、在Idea中创建Spring Assistant项目，选中web、Apache Kafka、lombok 二、导入Pom文件<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&q…
2021/8/2 7:08:45 人评论 次浏览 -
Spring Assistant框架搭建消息队列写入Kafka消费Windows单机测试
前提：已安装Java8、Maven 一、在Idea中创建Spring Assistant项目，选中web、Apache Kafka、lombok 二、导入Pom文件<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&q…
2021/8/2 7:08:45 人评论 次浏览 -
如何解决redis的并发竞争key问题
那么，如何学习Kafka源码？？ 我觉得最高效的方式就是去读最核心的源码，先看一张?Kafka结构图?以及?Kafka 源码全景图梳理一下关于?Kafka 框架，找到学习的重点。其次，我要说的就是一个Kafka源码解析的文档——《Kafka源码解析与实战》 前5章分别是：Kafka简介、Kaf…
2021/7/30 19:38:44 人评论 次浏览 -
如何解决redis的并发竞争key问题
那么，如何学习Kafka源码？？ 我觉得最高效的方式就是去读最核心的源码，先看一张?Kafka结构图?以及?Kafka 源码全景图梳理一下关于?Kafka 框架，找到学习的重点。其次，我要说的就是一个Kafka源码解析的文档——《Kafka源码解析与实战》 前5章分别是：Kafka简介、Kaf…
2021/7/30 19:38:44 人评论 次浏览 -
mysql默认索引数据结构
NameServer的部署 关于NameServer，我们之前的文章已经详细讲解过了集群化的内容，这里直接把它部署到三台机器上，作为一个高可用集群 Broker的部署 Broker的部署我们之前也有讲到过，主要使用的是4.5版本后的Dledger自动化切换主从的集群 Broker与NameServer之间的通信协…
2021/7/30 2:07:32 人评论 次浏览 -
mysql默认索引数据结构
NameServer的部署 关于NameServer，我们之前的文章已经详细讲解过了集群化的内容，这里直接把它部署到三台机器上，作为一个高可用集群 Broker的部署 Broker的部署我们之前也有讲到过，主要使用的是4.5版本后的Dledger自动化切换主从的集群 Broker与NameServer之间的通信协…
2021/7/30 2:07:32 人评论 次浏览 -
Python 创建一个Django项目
1 环境搭建及创建 1） 安装Django 方法一：pip install django 方法二：Pycharm File——settings——Project——Python Interpreter——Python3.9 添加Django安装，设置django的环境变量 3）创建Django项目 命令行至指定目录下，django-admin startproject djangotest 4…
2021/7/24 12:42:17 人评论 次浏览 -
Python 创建一个Django项目
1 环境搭建及创建 1） 安装Django 方法一：pip install django 方法二：Pycharm File——settings——Project——Python Interpreter——Python3.9 添加Django安装，设置django的环境变量 3）创建Django项目 命令行至指定目录下，django-admin startproject djangotest 4…
2021/7/24 12:42:17 人评论 次浏览 -
Java高级进阶学习资料！java创建list集合对象
Kafka的多副本冗余设计 不管是传统的基于关系型数据库设计的系统，还是分布式的如zookeeper、redis、Kafka、HDFS等等，实现高可用的办法通常是采用冗余设计，通过冗余来解决节点宕机不可用问题。 首先简单了解Kafka的几个概念： 物理模型逻辑模型Broker（节点）：Kafka服…
2021/7/23 14:06:47 人评论 次浏览
