1 允许 IPv4 TCP: 8000 0.0.0.0/0 为了更好的获取和更新系统和软件，建议您更新镜像源为华为云镜像源，详细操作，请参见如何使用自动化工具配置华为云镜像源(x86_64和ARM)？。 资源和成本规划 本次实践所用的资源配置及软件版本如表2中所示。当您使用不同的硬

查看更多 →

HTTP函数bootstrap启动文件如何创建？ 如果您需要创建HTTP函数，需要用到bootstrap启动文件，具体创建方法请参考bootstrap文件创建。 父主题： 创建函数

查看更多 →

部署Docker 搭建微信公众号后台——收发文本消息 手工部署GitLab（CentOS7.2） 手工部署RabbitMQ（CentOS 7.4） 部署和使用SVN PostgreSQL本地Slave搭建步骤 手工安装宝塔面板（CentOS 7.2） 基于 弹性云服务器 安装及部署Jenkins

查看更多 →

示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 bootstrap_servers：MQS连接地址和端口。 topic_name：要生产消息的Topic名称。 sasl_plain_username和sasl_plain_password：开启SASL_SSL认证时所使用的用户名和密码。 context.

查看更多 →

Thecartpress Wordpress AWCM final FreeSchool Nukebrowser Thinkphp AWStats FreshScripts NukeHall ThinkPHP5 RCE Baby Gekko FSphp Nullsoft Tiki Wiki BAROSmini

查看更多 →

值。 bootstrap_servers：实例连接地址与端口。 topic_name：Topic名称。 sasl_plain_username/sasl_plain_password：首次开启密文接入时设置的用户名与密码，或者创建用户时设置的用户名和密码。为了确保用户名和密码的安

查看更多 →

strategy”为“capacity”。 Kafka创建Topic时，支持基于“机架感知” 和 “跨AZ特性” 两种选项组合生成分区及副本的分配方案且支持 “--zookeeper” 和 “--bootstrap-server”两种方式 禁用机架策略 & 禁用跨AZ特性 (默认策略)。 基于

查看更多 →

jar，该jar包可在Kafka的客户端目录下获取。 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafka和com.huawei.bigdata.flink.examples

查看更多 →

clients}，对应的“myName”的取值范围为{topic的名称，组件业务用户，客户端ID}。 其中“producer_byte_rate”和“consumer_byte_rate”分别为生产限流的速度和消费限流的速度，其单位均为字节/秒。 如果“myType”选择为“topics_limit”，则命令行需修改为：

查看更多 →

jar，该jar包可在 MRS client目录下获取。 样例代码 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafka和com.huawei.flink.example.kafka.ReadFromKafka

查看更多 →

strategy”为“capacity”。 Kafka创建Topic时，支持基于“机架感知” 和 “跨AZ特性” 两种选项组合生成分区及副本的分配方案且支持 “--zookeeper” 和 “--bootstrap-server”两种方式 禁用机架策略 & 禁用跨AZ特性 (默认策略)。 基于

查看更多 →

MRS 3.3.1及之后版本，Kafka仅支持使用“--bootstrap-server”创建Topic，不再支持使用“--zookeeper”来创建Topic。 “--zookeeper” 和 “--bootstrap-server”两种方式的区别如下： “--zookeep

查看更多 →

sh对Token进行操作 为用户生成Token： ./kafka-delegation-tokens.sh --create --bootstrap-server <IP1:PORT, IP2:PORT,...> --max-life-time-period <Long: max

查看更多 →

sh对Token进行操作。 为用户生成Token： ./kafka-delegation-tokens.sh --create --bootstrap-server <IP1:PORT, IP2:PORT,...> --max-life-time-period <Long: max

查看更多 →

创建空白函数 创建空白函数时可以选择“事件函数”和“HTTP函数”两种函数类型。 HTTP函数专注于优化Web服务场景，用户可以直接发送HTTP请求到URL触发函数执行，从而使用自己的Web服务。HTTP函数只允许创建APIG/APIC的触发器类型，其他触发器不支持。 HTTP函

查看更多 →

模块的接口，生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafka和com.huawei.bigdata.flink.examples

查看更多 →

功能介绍 使用Structured Streaming，从kafka中读取广告请求数据、广告展示数据、广告点击数据，实时获取广告有效展示统计数据和广告有效点击统计数据，将统计结果写入kafka中。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark

查看更多 →

--zookeeper <ZooKeeper集群IP:2181/kafka> bin/kafka-topics.sh --list --bootstrap-server <Kafka集群IP:21007> --command-config config/client.properties

查看更多 →

--zookeeper <ZooKeeper集群IP:2181/kafka> bin/kafka-topics.sh --list --bootstrap-server <Kafka集群IP:21007> --command-config config/client.properties

查看更多 →

jar，该jar包可在kafka客户端目录下获取。 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafka和com.huawei.bigdata.flink.examples

查看更多 →

afkaJavaExample样例工程下的com.huawei.bigdata.flink.examples.WriteIntoKafka和com.huawei.bigdata.flink.examples.ReadFromKafka。 //producer代码 public class

查看更多 →