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

    • spring cloud eureka client

      前言 本文举例说明eureka client如何使用。 操作步骤 使用idea新建立工程com.nick.client,依赖配置加入 cloud discovery -> eureka discovery web -> web 修改application.pr

      开发者  >  博客
      作者： Nick Qiu
      发表时间： 2021-03-25 14:38:18
      1445
      0

    • Kafka快速入门系列(13) | Flume对接Kafka

        本篇博主带来的是Flume对接Kafka。 目录 1. Kafka与Flume比较2. Flume与kafka集成 1. Kafka与Flume比较 在企业中必须要清楚流式数据采集框架flume和kafka的定位是什么： 1. flume：cloudera公司研发

      开发者  >  博客
      作者： 不温卜火
      发表时间： 2020-12-02 14:22:22
      4004
      0

    • gaussdb是否支持创建kafka外部连接

      支持的外部数据封装器，我只看到了dfs_fdw和gc_fdw我想问一下是否支持kafka类型的，例如：CREATE SERVER kafka_server  FOREIGN DATA WRAPPER kafka_fdw 

      开发者  >  其他
      作者： yd_234386870
      86
      3

    • FusionInsight Flink使用SQL-Client（On Yarn、BETA）

             将sql-client-defaults.yaml（见附件）放入/opt/client/Flink/flink/conf中3.       将jaas.conf（见附件）放入/opt/client/Flink/flink/conf中4.       将kafka-clients

      开发者  >  其他
      作者： 南派三叔
      8669
      7

    • kafka 的架构

      讲一下kafka 的架构 一个典型的Kafka集群中包含若干Producer，若干broker，若干Consumer Group，以及一个Zookeeper集群。Kafka通过Zookeeper管理集群配置，选举leader，以及在Consumer Group发生变化时进行r

      开发者  >  博客
      作者： 孙中明
      发表时间： 2022-04-03 08:44:57
      548
      0

    • DeleteKafkaUserClientQuotaTask Deleting a User or Client Quota - API

      该API属于Kafka服务，描述: This API is used to submit a task of deleting a user or client quota from a Kafka instance. A job_id is returned if the task

      开发者 >  开发工具

    • 开源kafka manager链接开启kerbeors认证的MRS Kafka集群部署配置指南

      name = kafka4.       到kafka manager安装目录下，修改./conf/application.conf中的以下配置项：kafka-manager.zkhosts #配置为zookeeper 地址，默认有2个重复配置项，只保留1个kafka-manager

      开发者  >  其他
      作者： Lothar
      6790
      2

    • Kafka快速入门系列(1) | Kafka的简单介绍(一文令你快速了解Kafka)

      消息队列内部实现原理2 为什么需要消息队列 3. 什么是Kafka4. Kafka架构5. Kafka的好处6. 分布式的发布与订阅系统7. kafka的主要应用场景 1. Kafka的定义   Kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。

      开发者  >  博客
      作者： 不温卜火
      发表时间： 2020-12-01 15:20:24
      2668
      0

    • 传送Client专线业务发放快速体验

      熟悉传送Client专线业务开放的API接口，APP开发过程，以及APP验证过程。

      开发者  >  视频
      播放量  4953

    • Kafka分区未同步

      一、          节点故障或磁盘下线1.      Kafka节点服务异常通过FusionInsight Manager页面，选择“集群->Kafka”，查看当前Kafka集群当前状态，状态是否是良好；如果状态不是良好，说明Kafka服务异常。2.      磁盘下线通过FusionInsight

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

    • A(12)Kafka分区分配策略

      在 Kafka内部存在两种默认的分区分配策略：Range和 RoundRobin。 Range是默认策略。Range是对每个Topic而言的（即一个Topic一个Topic分），首先对同一个Topic里面的分区按照序号进行排序，并对消费者按照字母顺序进行排序。然后用Partiti

      开发者  >  博客
      作者： 百忍成金的虚竹
      发表时间： 2021-03-27 15:22:32
      1593
      0

    • 使用Python使用SSL连接到Kafka集群

      -keystore kafka.client.keystore.jks 系统将提示您输入密码。输入密钥库密码，这将列出密钥库文件的内容。您将能够看到*别名。 下面是运行shell脚本的示例: ./jkstopem.sh ~/client-cert kafka.client.keystore

      开发者  >  博客
      作者： kaliarch
      发表时间： 2023-12-10 13:37:41
      298
      0

    • Kafka连接工具与监控工具

      CMAK需zookeeper方式启动kafka https://github.com/yahoo/CMAK/releases 监控工具EFAK EFAK依赖于zookeeper方式启动的kafka https://github.com/smartloli/kafka-eagle-bin/b

      开发者  >  博客
      作者： QGS
      发表时间： 2024-04-26 22:13:44
      75
      0

    • 阿里四面：kafka何时、如何删除Topic？

      ReplicaStateMachine（副本状态机） 负责定义Kafka副本状态、合法的状态转换，以及管理状态之间的转换。 PartitionStateMachine（分区状态机） 负责定义Kafka分区状态、合法的状态转换，以及管理状态之间的转换。 本文看看Kafka是如何删除一个主题的。 前言 以为成功执行kafka-topics

      开发者  >  博客
      作者： JavaEdge
      发表时间： 2022-01-01 14:29:35
      1198
      0

    • Spark 操作 kafka

      sources ：像Kafka，Flume，Kinesis等这样的源，可通过额外的程序类获得 消费 先把数据接收过来，转换为spark streaming中的数据结构Dstream。接收数据的方式有两种：1.利用Receiver接收数据，2.直接从kafka读取数据。 在spark1

      开发者  >  博客
      作者： 武师叔
      发表时间： 2022-09-29 08:38:03
      173
      0

    • Kafka快速入门系列(14) | Kafka监控（两种）

        本篇博主带来的是Kafka的两种监控软件。 目录 一. Kafka Monitor二. Kafka Manager 一. Kafka Monitor 1. 上传jar包KafkaOffsetMonitor-assembly-0.4.6.jar到集群

      开发者  >  博客
      作者： 不温卜火
      发表时间： 2020-12-01 16:18:32
      1744
      0

    • Java实现Kafka生产者和消费者的示例

      Kafka简介 Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。 方式一：kafka-clients 引入依赖 在pom.xml文件中，引入kafka-clients依赖：

      开发者  >  博客
      作者： 万猫学社
      发表时间： 2021-06-28 08:21:38
      1558
      0

    • Flink消费kafka topic内容写入DWS

      Flink读取Kafka Topic消费内容写入DWS一、配置客户端进入集群客户端安装目录，例如“/opt/Bigdata/client/”，导入环境变量。cd /opt/Bigdata/client/ source bigdata_env执行kinit命令，输入用户密码进行用户认证。

      开发者  >  其他
      作者： Ivan-agatha
      444
      2

    • spring cloud eureka client

      前言本文举例说明eureka client如何使用。操作步骤使用idea新建立工程com.nick.client,依赖配置加入cloud discovery -> eureka discoveryweb -> web修改application.properties为application

      开发者  >  博客
      作者： Nick Qiu
      发表时间： 2020-10-23 04:43:57
      1802
      0

    • kafka配置命令

      /export/servers/kafka_2.11-1.0.0/bin/kafka-server-start.sh /export/servers/kafka_2.11-1.0.0/config/server.properties > /dev/null 2>&1 & 关闭 bin/kafka-server-stop

      开发者  >  博客
      作者： 百忍成金的虚竹
      发表时间： 2021-03-25 15:09:29
      1447
      0
    总条数： 10000
    点击加载更多