已找到关于"kafka client连接方式"的 10000 条记录

    • Kafka实例是否支持跨VPC访问？ - 分布式消息服务Kafka版

      步骤请参考同区域同帐号VPC互通。 利用VPC终端节点在不同VPC间建立跨VPC的连接通道，实现Kafka客户端通过内网访问Kafka实例。具体步骤请参考跨VPC访问Kafka实例。 父主题： 连接问题

      帮助中心 > 分布式消息服务Kafka版 > 常见问题 > 连接问题

    • Kafka连接问题排查和解决 - 分布式消息服务Kafka版

      Kafka连接问题排查和解决 概述 本章节主要描述Kafka连接问题的排查和解决。 问题分类 当您发现与Kafka实例连接出现异常时，可以根据本文的内容，从以下几个方面进行排查。 检查网络 检查Consumer和Producer的配置 客户端连接问题-Java客户端 客户端连接问题-Go客户端

      帮助中心 > 分布式消息服务Kafka版 > 故障排除

    • Kafka生产连接失败

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

      开发者  >  博客
      作者： Summer_
      发表时间： 2022-04-28 06:36:37
      695
      0

    • Kafka实例连接数有限制吗？ - 分布式消息服务Kafka版

      实例规格 单个代理客户端总连接数上限 kafka.2u4g.cluster.small 2000 kafka.2u4g.single.small 2000 kafka.2u4g.cluster 2000 kafka.2u4g.single 2000 kafka.4u8g.cluster

      帮助中心 > 分布式消息服务Kafka版 > 常见问题 > 连接问题

    • 运行Kafka作业

      选择“组件管理 > Kafka > 实例”，查看Kafka角色实例的IP地址。记录Kafka角色实例中任意一个的IP地址即可。 运行Kafka作业 MRS 3.x及之后版本客户端默认安装路径为“/opt/Bigdata/client”，MRS 3.x

      开发者 >  开发服务

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

      连接Kafka网络要求 客户端可以通过公网连接Kafka实例，也可以通过内网连接Kafka实例。使用内网连接时，注意以下几点： 如果客户端和Kafka实例部署在同一个VPC内，网络默认互通。 如果客户端和Kafka实例部署在不同VPC中，由于VPC之间逻辑隔离，客户端和Kafka

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

    • 配置Kafka实例的公网访问 - 分布式消息服务Kafka版

      通过公网访问Kafka（开启SSL加密）。 关闭公网访问（不支持修改SASL开关） 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择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学习一: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】解决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入门三：几种消费方式

      deserializer","org.apache.kafka.common.serialization.StringDeserializer"); props.put("value.deserializer","org.apache.kafka.common.serialization.

      开发者  >  其他
      作者： 多米诺的古牌
      20
      2

    • 【kafka】浅谈kafka常考特性

      家浅浅分享一下之前准备的`kafka相关知识点`，等看机会的时候可以拿来复习复习。kafka也算是面试常考的组件，一些基本概念就不再写了，就写写面试里常考常问的一些点。 kafka的基本组件 1.  Broker：通俗理解成一台部署了kafka的服务器就是一个Broke

      开发者  >  博客
      作者： 在下uptown
      发表时间： 2022-11-07 11:14:36
      190
      0

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

      principal信息为下载的认证用户的用户名5、通过kafka客户端命令行，确认没有topic名称为topic1的topic6、启动代码7、开启客户端kafka消费命令行监控 topic18、通过postman工具发送post请求9、查看客户端kafka消费命令监控到的信息是否和请求中的一致1

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

    • 注册DMS kafka实例

      注册DMS kafka实例 功能介绍 该接口用于注册DMS kafka实例。 在注册DMS kafka实例前，需要开放9091端口。

      开发者 >  开发服务

    • kafka问题

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

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

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

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

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

    • Kafka使用最佳实践-Kafka常见的使用误区

      1. kafka集群单个节点磁盘挂载的越多越好 业界Kafka的标准使用方式是作为临时缓存使用。因此，很多人会误以为，kafka的每个节点只要存储够大就行，不用关心其他的指标。官方并不建议kafka单节点关在多个磁盘，因为磁盘越多，表示需要更多的处理线程去管理（num.io.th

      开发者  >  博客
      作者： FI小粉丝
      发表时间： 2021-05-28 07:06:50
      2219
      0

    • 使用python库confluent_kafka连接安全集群Kafka

             从源码安装confluent-kafka python库（此步骤依赖上一步骤的librdkafka so链接库）：$ pip install --no-binary :all: confluent-kafka 6.       编写测试用例测试confluent-kafka使用：此处只提供客

      开发者  >  其他
      作者： suwei
      2568
      1

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

      apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1127)Caused by: java.lang.ClassNotFoundException: org.apache.kafka.clients.producer

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

    • Kafka入门三：几种消费方式

      deserializer","org.apache.kafka.common.serialization.StringDeserializer"); props.put("value.deserializer","org.apache.kafka.common.serialization.

      开发者  >  其他
      作者： 多米诺的古牌
      30
      1
    总条数： 10000
    点击加载更多