已找到以下 10000 条记录。

    • 线下kafka如何对接mrs的kafka？

      大数据的项目。想把客户线下kafka的消息传递到mrs的kafka中。这个可以如何实现？

      开发者  >  其他
      作者： 江西时励-朱君
      4072
      2

    • 与开源Kafka的差异 - 分布式消息服务Kafka版

      与开源Kafka的差异 分布式消息服务Kafka版在兼容开源Kafka基础上，对版本特性做了一定程度的定制和增强，所以，除了拥有开源Kafka的优点，分布式消息服务Kafka版提供了更多可靠、实用的特性。 表1 分布式消息服务Kafka版与开源Kafka的差异说明 对比类 对比项

      帮助中心 > 分布式消息服务Kafka版 > 产品介绍

    • 使用VPCEP实现跨VPC访问Kafka - 分布式消息服务Kafka版

      跨VPC访问Kafka实例原理图 步骤一：创建终端节点服务 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。 单击Kafka实例名称，进入实例详情页面。

      帮助中心 > 分布式消息服务Kafka版 > 用户指南 > 连接实例 > 配置Kafka网络连接

    • Kafka - MapReduce服务 MRS

      Kafka Kafka jar包冲突列表 Jar包名称 描述 kafka_2.11-*.jar 连接Kafka服务必须的jar包。 kafka-clients-*.jar 连接Kafka服务必须的jar包。 解决方案 Kafka不建议使用开源版本的包。 父主题： MRS应用开发开源jar包冲突列表说明

      帮助中心 > MapReduce服务 MRS > 开发指南（LTS版） > MRS应用开发开源jar包冲突列表说明

    • Kafka使用最佳实践-Kafka集群操作规范

      Kafka集群在使用过程中会出现各种各样的操作场景，修改配置参数、集群异常等各种重启场景等，操作过程中需要注意一些注意事项。 离线重启kafka集群 如果需要修改kafka服务端的配置，点击保存配置后，不要勾选“重新启动受影响的服务或实例”。 重启kafka进程前，需要

      开发者  >  博客
      作者： FI小粉丝
      发表时间： 2021-05-25 09:05:58
      2361
      0

    • 连接Kafka网络要求 - 分布式消息服务Kafka版

      客户端连接Kafka实例的方式如表1所示。 表1 连接方式说明 连接方式 实现方式 参考文档 公网连接 客户端通过IPv4地址访问Kafka实例：在Kafka控制台开启公网访问，配置弹性公网IP，客户端通过弹性公网IP访问Kafka实例。 客户端通过IPv6地址访问Kafka实例：在

      帮助中心 > 分布式消息服务Kafka版 > 用户指南 > 连接实例 > 配置Kafka网络连接

    • 【FI hd 6513】【开源flink 华为kafka】 开源flink连接华为kafka问题

      k kafka connector中开源kafka-client替换为kafka-clients-2.4.0-h0.cbu.mrs.313.r103、在flink-conf.yml 中配置了认证信息#认证参数java.security.auth.login.config: /data/abc/jaas

      开发者  >  其他
      作者： menghe
      665
      6

    • 玩转Kafka—Spring&Go整合Kafka

      com/stealthly/go_kafka_client OptioPay：https://github.com/optiopay/kafka https://github.com/nuance/kafka https://github.com/jdamick/kafka.go Con

      开发者  >  博客
      作者： Barry Yan
      发表时间： 2022-10-16 11:13:40
      123
      0

    • kafka

      kafka 可以脱离zookeeper单独使用吗？为什么？

      开发者  >  其他
      作者： 火灵
      2871
      2

    • Spring-kafka对接华为FusionInsight Kafka样例

      nsumer查看对接安全认证kafka:下载附件中的样例代码，注意pom.xml中修改了依赖，将默认的apache的kafka-client包替换为华为自带的，该依赖包的获取参考如下链接配置mavenhttps://bbs.huaweicloud.com/forum/thread-88552-1-1

      开发者  >  其他
      作者： suwei
      5032
      0

    • Kafka实战：如何把Kafka消息时延秒降10倍

      动一个投递线程（Deliver Thread）调用Kafka的SDK接口，并发送3条消息到DMS（分布式消息服务），每条消息大小3k，需要等待3条消息都被处理完成后才会返回请求响应⑧。当消息达到DMS后，业务消费进程调用Kafka的消费接口把消息取出来，然后将每条消息放到一个响应线程(Response

      开发者  >  博客
      作者： 牵小柴散步
      发表时间： 2018-05-15 03:27:07
      3637
      0

    • MRS Flink使用SQL-Client对接Hive

      根据产品文档安装Flink客户端； 2.将sql-client-defaults.yaml放入/opt/client/Flink/flink/conf中 3.将jaas.conf放入/opt/client/Flink/flink/conf中 Client {com.sun.security.auth

      开发者  >  博客
      作者： yangxiao_mrs
      发表时间： 2021-09-29 09:38:40
      1872
      1

    • kafka问题

      zk里面确认已经删除干净，同时节点上也没有了该topic的信息。重启了kafka，再重新创建这个topic，仍然报这些问题。最后我想卸载kafka，并重新部署kafka，结果删也删不掉，也无法恢复正常。如下图。求帮忙。。该集群比较重要，没办法全部ch

      开发者  >  其他
      作者： 丫妹子
      2287
      6

    • Client-go 的使用

      通过clientset中不同的client和client中不同资源对象的方法实现对kubernetes中资源对象的增删改查等操作，常用的client有CoreV1Client、AppsV1beta1Client、ExtensionsV1beta1Client等。 本篇为简单利用client-go 实现简单的k8s资源操作，后期利用例如

      开发者  >  博客
      作者： kaliarch
      发表时间： 2022-02-15 05:45:26
      1547
      0

    • 【kafka】解决kafka-tool连接上kafka，brokers和topics不显示问题

      注意:该方法仅适用于不关心kafka数据的环境，慎用、慎用、慎用。生产环境禁止使用，用了也差不多准备交接了吧！ 步骤: 1.进入到kafka安装目录，关掉kafka进程 sh kafka-server-stop.sh 2.删除kafka的所有topics，一个个删除 ./kafka-topics

      开发者  >  博客
      作者： 钧瑜
      发表时间： 2023-10-26 00:00:07
      13
      0

    • kafka学习一:docker安装kafka

      - KAFKA_CFG_ADVERTISED_LISTENERS=CLIENT://kafka:9092,EXTERNAL://{{自己的公网ip}}:9093 + - KAFKA_CFG_INTER_BROKER_LISTENER_NAME=CLIENT 复制 将

      开发者  >  博客
      作者： 仙士可
      发表时间： 2023-06-30 12:28:22
      25
      0

    • Kafka Shell命令介绍 - MapReduce服务 MRS

      Kafka Shell命令介绍 前提条件 Kafka的Linux客户端已安装。安装方法可参考安装客户端。 常用的Shell命令指南 Shell命令执行方法： 进入Kafka客户端任意目录。 初始化环境变量。 source /opt/client/bigdata_env 如果当前集

      帮助中心 > MapReduce服务 MRS > 开发指南（普通版_2.x） > Kafka开发指南 > Kafka应用开发常见问题 > Kafka接口介绍

    • 分布式消息服务Kafka版 - 分布式消息服务Kafka版

      华为云 分布式消息服务Kafka版 分布式消息服务Kafka版（Distributed Message Service for Kafka）是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。 免费体验 图说Kafka 立即使用

      帮助中心 > 分布式消息服务Kafka版 > 成长地图

    • 【flink 1.7.2】【向Kafka生产】ClassNotFoundException: org.apache.kafka.

      org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529)        at org.apache.flink.client.program.PackagedProgram

      开发者  >  其他
      作者： 黄金振
      3606
      4

    • Kafka生产连接失败

      sssd”重启进程。如果属组中无kafkaadmin或supergroup或kafka，说明用户没有配置kafka角色，需添加kafka角色信息；如果只有kafka，需要查看该用户是否有topic的生产权限，查看命令如下： kafka-acls.sh --authorizer-properties

      开发者  >  博客
      作者： Summer_
      发表时间： 2022-04-28 06:36:37
      695
      0
    总条数： 10000
    点击加载更多