内容选择
    内容分类
    学堂 博客 论坛 开发服务 开发工具 直播 视频 用户
    时间
    一周 一个月 三个月
    内容选择
    全部
    内容选择
    内容分类
    • 学堂
    • 博客
    • 论坛
    • 开发服务
    • 开发工具
    • 直播
    • 视频
    • 用户
    时间
    • 一周
    • 一个月
    • 三个月
    重置 确定

    • Kafka修改配置详解

      Kafka修改配置有两个命令：kafka-topics.sh和kafka-configs.sh。kafka-topics.sh主要是修改单个topic的配置，支持修改的配置参数见附录一；kafka-configs.sh支持修改topic、broker、user和client级别的

      开发者  >  其他
      作者： Summer_
      5247
      0

    • Kafka简介及使用PHP处理Kafka消息

      支持离线数据处理和实时数据处理。 Kafka的架构： kafka架构图   Kafka的整体架构非常简单，producer、broker（kafka）和consumer都可以有多个。Producer，consumer实现Kafka注册的接口，数据从producer

      开发者  >  博客
      作者： Lansonli
      发表时间： 2021-09-27 15:12:05
      1220
      0

    • Kafka快速入门系列(12) | Kafka Streams的简单介绍

        本篇博主带来的是Kafka Streams的相关知识。 目录 1. 什么是Kafka Streams2. Kafka Streams特点3. 为什么要有Kafka Stream4. Kafka Stream数据清洗案例1. 需求2. 需求分析3. 案例实操 1. 什么是Kafka Streams

      开发者  >  博客
      作者： 不温卜火
      发表时间： 2020-12-02 23:47:10
      3721
      0

    • Flink SQL Client综合实战

      本篇概览 在《Flink SQL Client初探》一文中，我们体验了Flink SQL Client的基本功能，今天来通过实战更深入学习和体验Flink SQL； 实战内容 本次实战主要是通过Flink SQL Client消费kafka的实时消息，再用各种SQL操作对数据进行查询统计，内容汇总如下：

      开发者  >  博客
      作者： 程序员欣宸
      发表时间： 2022-04-11 11:54:13
      728
      0

    • 【Kafka】Kafka 基础知识总结

      outh 1. Kafka概念 1.1 Kafka组成模块 面试官：你先说说Kafka由什么模块组成？ Kafka其实是一款基于发布与订阅模式的消息系统，如果按常理来设计，大家是不是把消息发送者的消息直接发送给消息消费者？但Kafka并不是这么设计的，Kafka消息的生产者会对消

      开发者  >  博客
      作者： JavaSouth南哥
      发表时间： 2024-12-04 17:43:05
      0
      0

    • Flink消费kafka消息实战

      S: PLAINTEXT://kafka1:9092 KAFKA_LISTENERS: PLAINTEXT://:9092 KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 KAFKA_CREATE_TOPICS:

      开发者  >  博客
      作者： 程序员欣宸
      发表时间： 2022-07-27 04:43:45
      369
      0

    • 创建Kafka角色

      权限”的表格中选择“待操作集群的名称 > Kafka > Kafka Topic生产和消费权限”。在指定Topic的“权限”列，勾选“Kafka消费者权限”。在“配置资源权限”的表格中选择“待操作集群的名称 > Kafka > Kafka Topic生产和消费权限”。在指定Top

      开发者  >  其他
      作者： 晋红轻
      1358
      0

    • kafka 就近消費

      ## 背景 在搭建Kafka集群时，通常会按照机架部署机器。Kafka在新建topic时，为了提高集群的可靠性， 会将同一分区的不同副本分布在不同的机架内，这样即使有一个机架上的机器宕掉，也不会影响服务的可用性和稳定性 如下图：集群中有三个机架，每个机架内部3个节点，在这个集群内创建了3分区3副本的topic

      开发者  >  其他
      作者： 尘枫
      1523
      0

    • 什么是 Detached client

      数据丢失或者操作失败。而在 Detached Client 模式下，即使连接中断，服务器也能够继续处理请求，客户端可以稍后重新连接以获得结果。 Detached Client 的工作原理 为了理解 Detached Client 的工作原理，可以考虑以下几个关键步骤： 客户端发送请求：在

      开发者  >  博客
      作者： 汪子熙
      发表时间： 2024-11-03 11:49:02
      0
      0

    • Python：kafka基本操作

      https://pykafka.readthedocs.io/ kafka-python https://pypi.org/project/kafka-python/ https://github.com/dpkp/kafka-python http://kafka-python.readthedocs.io/

      开发者  >  博客
      作者： 彭世瑜
      发表时间： 2021-08-13 15:47:22
      1027
      0

    • 玩转Kafka—Kafka高性能原因分析

      玩转Kafka—Kafka高性能原因分析 Kafka最大的特点：高吞吐，即使在普通的机械硬盘下也可以达到每秒几百万的处理量 对比RocketMQ： 那么Kafka为什么能实现如此高的吞吐量呢？ 主要以下四个方面： 磁盘的顺序读写 页缓存 零拷贝技术 批量处理 下面我们来分别解释下

      开发者  >  博客
      作者： Barry Yan
      发表时间： 2022-11-29 14:29:55
      131
      0

    • kafka消费的三种模式_快速认识Kafka

      kreps非常喜欢franz kafka,觉得kafka这个名字很酷，因此将linkedin的消息传递系统命名为完全不相干的kafka，没有特别含义。 2.解决什么问题 kafka开发的主要初衷目标是构建一个用来处理海量日志，用户行为和网站运营统计等的数据处理框架。在结合了数据挖掘，行为分析，

      开发者  >  其他
      作者： 多米诺的古牌
      38
      1

    • Client-go源码分析之WorkQueue

      anel来处理会存在处理效率低，存在数据大并发量，数据积压等其他异常情况，为此client-go单独将workqueue提出来，作为公共组件，不仅可以在Kubernetes内部使用，还可以供Client-go使用，用户侧可以通过Workqueue相关方法进行更加灵活的队列处理，如

      开发者  >  博客
      作者： kaliarch
      发表时间： 2022-02-21 04:56:07
      1425
      0

    • Flink 操作 kafka （一）

      月更文挑战」的第30天，点击查看活动详情 Flink 操作 kafka https://zhuanlan.zhihu.com/p/92289771 flink 提供了一个特有的 kafka connector 去读写 kafka topic 的数据。这样在 flink 消费 kafka 数据时，就可以通过 flink

      开发者  >  博客
      作者： 武师叔
      发表时间： 2022-09-29 08:36:57
      212
      0

    • Kafka实战(七) - 优雅地部署 Kafka 集群

      言归正传，I/O模型与Kafka的关系几何？ Kafka Client 底层使用了Java的selector，而selector 在Linux上的实现机制是epoll在Windows平台上的实现机制是select 因此在这一点上将Kafka部署在Linux上是有优势的，能够获得更高效的I/O性能。

      开发者  >  博客
      作者： JavaEdge
      发表时间： 2021-06-03 17:27:53
      1538
      0

    • Kafka学习之路 （一）Kafka的简介

      统和消息系统。Kafka主要设计目标如下：可靠性 - Kafka是分布式，分区，复制和容错的。可扩展性 - Kafka消息传递系统轻松缩放，无需停机。耐用性 - Kafka使用分布式提交日志，这意味着消息会尽可能快地保留在磁盘上，因此它是持久的。性能 - Kafka对于发布和订阅

      开发者  >  博客
      作者： 技术火炬手
      发表时间： 2018-11-15 15:01:54
      3922
      0

    • Kafka入门

      第一，kafka简介以及适用场景，第二，kafka设计原理，三，常见问题及思考。 一、kafka简介及适用场景 **kafka官网上对 kafka 的定义：**一个分布式发布-订阅消息传递系统。主要特点包括高吞吐量、持久化（消息持久化到磁盘，支持批量和实时处理）、可扩展性、容错性。

      开发者  >  博客
      作者： Tester_muller
      发表时间： 2022-06-30 16:45:38
      800
      0

    • KAFKA EAGLE 监控MRS kafka之操作实践

      1.Kafka Eagle简介 Kafka eagle 是一款分布式、高可用的kafka监控软件，提供丰富的kafka监控指标，例如：Kafka集群的Broker数、Topic数、Consumer数、Topic LogSize Top10、Topic Capacity Top1

      开发者  >  博客
      作者： 啊喔YeYe
      发表时间： 2022-12-06 12:33:20
      694
      1

    • kafka的Docker镜像使用说明(wurstmeister/kafka)

      exec kafka-docker_kafka_2 \ kafka-console-consumer.sh \ --topic topic001 \ --bootstrap-server kafka-docker_kafka_1:9092,kafka-docker_kafka_2:9092

      开发者  >  博客
      作者： 程序员欣宸
      发表时间： 2022-07-25 04:48:10
      757
      0

    • 使用Kafka客户端

      工具查看帮助并使用。./kafka-console-consumer.sh：Kafka消息读取工具./kafka-console-producer.sh：Kafka消息发布工具./kafka-topics.sh：Kafka Topic管理工具命令具体使用方法可参考《应用开发指南》

      开发者  >  其他
      作者： 晋红轻
      1775
      0
    总条数： 10000
    点击加载更多