1391
    推荐
    254k
    浏览
    kafka入门介绍
    Kafka作为一个分布式的流平台,这到底意味着什么?我们认为,一个流处理平台具有三个关键能力:1. 发布和订阅消息(流),在这方面,它类似于一个消息队列或企业消息系统。2. 以容错(故障转移)的方式存储消息(流)。3. 在消息流发生时处理它们。 什么是kafka的优势?它主要应用于2大类应用:1....
     半兽人 发布于7年前
    723
    推荐
    2.5k
    浏览
    kubeadm 创建 k8s集群(实战)
    环境- CentOS Linux 7.9- ip: 10.211.55.5 关闭 swap 分区如果开启了 swap 分区,kubelet 可能会启动失败,故需要在每台机器上关闭 swap 分区:``` bashsudo swapoff -a```为了防止开机自动挂载 swap 分区,可以注释 `...
     半兽人 发布于1年前
    455
    推荐
    120k
    浏览
    kafka命令大全
    整理kafka相关的常用命令。 管理``` 创建topic(4个分区,2个副本)bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic test kaf...
     半兽人 发布于5年前
    423
    推荐
    1.4k
    浏览
    kubeadm 创建高可用k8s集群(实战)
    环境centerOS 7.5master:- m1: 10.0.19.91- m2: 10.0.19.92- m3: 10.0.19.93node:- n1: 10.0.19.127- n2: 10.0.19.128负载均衡地址和端口:- 10.0.19.1:8443 开始前[必做]- [安装ku...
     半兽人 发布于10月前
    321
    推荐
    70k
    浏览
    Kafka Broker配置
    3.1 Broker配置基本配置如下:* broker.id* log.dirs* zookeeper.connect下文将详细论述了主题级别配置和默认值。 kafka >= 0.10版名称|描述|类型|默认|有效值|重要程度---|---|---|---|---|---|zookeeper.co...
     半兽人 发布于5年前
    238
    推荐
    121k
    浏览
    Kafka的使用场景
    下面是一些关于`Apache kafka`非常流行的使用场景。这些领域的概述,可查看[博客文章](https://engineering.linkedin.com/distributed-systems/log-what-every-software-engineer-should-know-abo...
     半兽人 发布于5年前
    144
    推荐
    11k
    浏览
    kubernetes Pod介绍
    Pod是Kubernetes的最重要也最基本的概念,如图所示是Pod的组成示意图,我们看到每个Pod都有一个特殊的被称为“根容器”的Pause容器。Pause容器对应的镜像属于Kubernetes平台的一部分,除了Pause容器,每个Pod还包含一个或多个紧密相关的用户业务容器。 为什么Kubern...
     半兽人 发布于3年前
    121
    推荐
    2k
    浏览
    kafka集群安装搭建
    kafka集群安装搭建接上一步,[单集群](/6)已经搭建好之后。 设置多个broker集群到目前,我们只是单一的运行一个broker,没什么意思。对于Kafka,一个broker仅仅只是一个集群的大小,所有让我们多设几个broker。首先为每个broker创建一个配置文件: cp con...
     半兽人 发布于7月前
    98
    推荐
    10k
    浏览
    kafka通过开始和结束时间,重新消费消息 - java
    项目说明通过传入开始和结束时间戳,重新消费kafka历史消息。```public static void main(String[] args) { String startTime = "2018-08-14 21:19:09"; // 开始时间 String endTi...
     半兽人 发布于3年前
    92
    推荐
    80k
    浏览
    kafka消费者Java客户端
    一个从kafka集群中获取消息的java客户端。kafka客户端从kafka集群中获取消息,并透明地处理kafka集群中出现故障broker,透明地调节适应集群中变化的数据分区。也和broker交互,负载平衡消费者。 public class KafkaConsumer extends ...
     半兽人 发布于5年前
1 / 56 跳转到