- 一、无权限创建Topic会报错“ERROR kafka.admin.AdminOperationException: Error while deleting topic topicName解决办法是使用具有kafkaadmin权限的用户。二、“topic.enable”配置为falseFusionInsight Manager页面“集群->Kafka->配置->全部配置”查看Kafka服务... 一、无权限创建Topic会报错“ERROR kafka.admin.AdminOperationException: Error while deleting topic topicName解决办法是使用具有kafkaadmin权限的用户。二、“topic.enable”配置为falseFusionInsight Manager页面“集群->Kafka->配置->全部配置”查看Kafka服务...
- 一、 无权限创建Topic会报错“ERROR org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /config/topics/topicName。解决办法是使用具体kafkaadmin权限的用户。二、 Quota限制创建Topic会报错“Nodes number exceed ... 一、 无权限创建Topic会报错“ERROR org.apache.zookeeper.KeeperException$NoAuthException: KeeperErrorCode = NoAuth for /config/topics/topicName。解决办法是使用具体kafkaadmin权限的用户。二、 Quota限制创建Topic会报错“Nodes number exceed ...
- Kafka查看Topic的describe、list信息、不可用分区、未完全同步的分区 Kafka查看Topic的describe、list信息、不可用分区、未完全同步的分区
- 如何创建Topic及查看Topic的describe信息 如何创建Topic及查看Topic的describe信息
- java版，读取CSV数据发送到kafka java版，读取CSV数据发送到kafka
- 实践如何将flink数据集sink到kafka 实践如何将flink数据集sink到kafka
- kafka是apache基金会管理的开源流处理平台(官网http://kafka.apache.org/)，但国内大多数人对其认知基本都是消息队列，所以我们先来了解下什么是消息队列。 消息队列消息队列顾名思义就是存储消息的一个队列，消息生产者(producer) 往消息队列中投放消息， **消费者(consumer)**读取消息队列中的内容。在消息队列中的每条消息都会有个位置，就好比数组中的... kafka是apache基金会管理的开源流处理平台(官网http://kafka.apache.org/)，但国内大多数人对其认知基本都是消息队列，所以我们先来了解下什么是消息队列。 消息队列消息队列顾名思义就是存储消息的一个队列，消息生产者(producer) 往消息队列中投放消息， **消费者(consumer)**读取消息队列中的内容。在消息队列中的每条消息都会有个位置，就好比数组中的...
- 以SAP Data Intelligence标准的示例Graph com.sap.demo.http.server为例，将其json代码保存到本地，使用json编辑器查看：operator之间有8条线连接，对应json文件里connections数组里的8个元素：每个元素包含source和target两个对象。以下图为例：src对象代表图中的get port：target代表名为reques... 以SAP Data Intelligence标准的示例Graph com.sap.demo.http.server为例，将其json代码保存到本地，使用json编辑器查看：operator之间有8条线连接，对应json文件里connections数组里的8个元素：每个元素包含source和target两个对象。以下图为例：src对象代表图中的get port：target代表名为reques...
- 首先本地将kafka的docker容器镜像下载到本地并运行：docker search kafkadocker pull spotify/kafkadocker run --name kafka3 spotify/kafkadocker ps命令，查看tcp端口号：新建一个graph，使用典型的生产者-消费者模型：将Data Generator生成的数据交给kafka Producer op... 首先本地将kafka的docker容器镜像下载到本地并运行：docker search kafkadocker pull spotify/kafkadocker run --name kafka3 spotify/kafkadocker ps命令，查看tcp端口号：新建一个graph，使用典型的生产者-消费者模型：将Data Generator生成的数据交给kafka Producer op...
- 一、创建主题和分区/// <summary>/// 创建分区(更新分区)/// </summary>/// <param name="topic"></param>/// <param name="Partitions"></param>/// <returns></returns>[HttpGet("PartitionUpdate")]public async Task Partitio... 一、创建主题和分区/// <summary>/// 创建分区(更新分区)/// </summary>/// <param name="topic"></param>/// <param name="Partitions"></param>/// <returns></returns>[HttpGet("PartitionUpdate")]public async Task Partitio...
- @TOC 一、微服务场景下Kafka的使用 1.Kafka的安装Kafka下载网址：https://archive.apache.org/dist/kafka/Kafka的安装可以参考本人其他文章Docker下安装：https://blog.csdn.net/aa2528877987/article/details/123589123?spm=1001.2014.3001.5501 2.Ka... @TOC 一、微服务场景下Kafka的使用 1.Kafka的安装Kafka下载网址：https://archive.apache.org/dist/kafka/Kafka的安装可以参考本人其他文章Docker下安装：https://blog.csdn.net/aa2528877987/article/details/123589123?spm=1001.2014.3001.5501 2.Ka...
- 启动kafka启动zookeeper新版本中将不再依赖外部的zookeeper$ bin/zookeeper-server-start.sh config/zookeeper.properties启动kafka$ bin/kafka-server-start.sh config/server.properties创建一个Topic$ bin/kafka-topics.sh --create... 启动kafka启动zookeeper新版本中将不再依赖外部的zookeeper$ bin/zookeeper-server-start.sh config/zookeeper.properties启动kafka$ bin/kafka-server-start.sh config/server.properties创建一个Topic$ bin/kafka-topics.sh --create...
- SpringCloud微服务日志可以写入file 再通过filebeat写入logstash, 或者直接写入logstash。日志写入kafka,可以利用kafak的高吞吐量高性能来降低系统延迟，之后再异步写入logstash. 启动kafka服务kafka介绍与安装 启动zookeeper./bin/zookeeper-server-start.sh ./config/zookeeper.... SpringCloud微服务日志可以写入file 再通过filebeat写入logstash, 或者直接写入logstash。日志写入kafka,可以利用kafak的高吞吐量高性能来降低系统延迟，之后再异步写入logstash. 启动kafka服务kafka介绍与安装 启动zookeeper./bin/zookeeper-server-start.sh ./config/zookeeper....
- kafka SpringBoot 启动zookeeper./bin/zookeeper-server-start.sh ./config/zookeeper.properties 启动kafka./bin/kafka-server-start.sh ./config/server.properties 创建topicbin/kafka-topics.sh --create --topic ... kafka SpringBoot 启动zookeeper./bin/zookeeper-server-start.sh ./config/zookeeper.properties 启动kafka./bin/kafka-server-start.sh ./config/server.properties 创建topicbin/kafka-topics.sh --create --topic ...
- kafka介绍与安装Apache Kafka® 是 一个分布式流处理平台，是一个发布订阅系统Kafka适合什么样的场景?构造实时流数据管道，它可以在系统或应用之间可靠地获取数据。 (相当于message queue构建实时流式应用程序，对这些流数据进行转换或者影响。 (就是流处理，通过kafka stream topic和topic之间内部进行变化)常用的场景将微服务日志输入到kafka中，... kafka介绍与安装Apache Kafka® 是 一个分布式流处理平台，是一个发布订阅系统Kafka适合什么样的场景?构造实时流数据管道，它可以在系统或应用之间可靠地获取数据。 (相当于message queue构建实时流式应用程序，对这些流数据进行转换或者影响。 (就是流处理，通过kafka stream topic和topic之间内部进行变化)常用的场景将微服务日志输入到kafka中，...
上滑加载中
推荐直播
-
Skill 构建 × 智能创作：基于华为云码道的 AI 内容生产提效方案2026/03/25 周三 19:00-20:00
余伟，华为云软件研发工程师/万邵业（万少），华为云HCDE开发者专家
本次直播带来两大实战：华为云码道 Skill-Creator 手把手搭建专属知识库 Skill；如何用码道提效 OpenClaw 小说文本，打造从大纲到成稿的 AI 原创小说全链路。技术干货 + OPC创作思路，一次讲透！
回顾中 -
码道新技能，AI 新生产力——从自动视频生成到开源项目解析2026/04/08 周三 19:00-21:00
童得力-华为云开发者生态运营总监/何文强-无人机企业AI提效负责人
本次华为云码道 Skill 实战活动，聚焦两大 AI 开发场景：通过实战教学，带你打造 AI 编程自动生成视频 Skill，并实现对 GitHub 热门开源项目的智能知识抽取，手把手掌握 Skill 开发全流程，用 AI 提升研发效率与内容生产力。
回顾中 -
华为云码道：零代码股票智能决策平台全功能实战2026/04/18 周六 10:00-12:00
秦拳德-中软国际教育卓越研究院研究员、华为云金牌讲师、云原生技术专家
利用Tushare接口获取实时行情数据，采用Transformer算法进行时序预测与涨跌分析，并集成DeepSeek API提供智能解读。同时，项目深度结合华为云CodeArts（码道）的代码智能体能力，实现代码一键推送至云端代码仓库，建立起高效、可协作的团队开发新范式。开发者可快速上手，从零打造功能完整的个股筛选、智能分析与风险管控产品。
回顾中
热门标签