--replication-factor 主题的备份数 --bootstrap-server Kafka集群IP:21007 --command-config ../config/client.properties 其中，使用“--bootstrap-server”方式创建Topic时，需配置“rack

查看更多 →

crt") print('start producer') producer = KafkaProducer(bootstrap_servers=conf['bootstrap_servers'], sasl_mechanism="PLAIN"

查看更多 →

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

查看更多 →

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

查看更多 →

他业务系统可使用接口调用节点，通过接口调用节点，使机器人能够准确回答用户的问题。 在左上角节点列表中，拖拽“接口调用”节点到中间空白区域，同时界面右侧展开“接口调用”页签。 图1 接口调用 根据表1设置节点名称、模式（配置模式或者函数模式）、请求方式、调用地址及入参和出参信息。 表1

查看更多 →

在图片界面单击左侧工具栏“补框”，绘制2D框，此时右侧标注列表只展示关联对象的标注物。键盘按键“ESC”退出绘制状态，右侧标注列表展示所有的标注物。 图2 2D补框 在点云界面单击左侧工具栏“AI标注”（快捷键b），框选3D，此时右侧标注列表只展示关联对象的标注物。双击空白处退出绘制状态，右侧标注列表展示所有的标注物。

查看更多 →

单击“接口”页签，选择需要添加的关键字所在的文件夹，单击需要添加的关键字右侧的或鼠标悬浮在关键字区域拖拽至测试步骤区域。 单击“保存”，完成添加组合关键字。 对于已添加的组合关键字，将鼠标悬浮在关键字区域时，可以选择进行以下操作。 单击“关键字目录”右侧的，可以创建文件夹。可以参照步骤1在自定义的文件夹内创建组合关键字。

查看更多 →

云手机 服务器 CPH”。 进入云手机服务器页面。 单击左侧导航栏的“实例管理”。 在云手机列表，选择一台云手机实例，单击右侧“操作”列的“更多 > ADB公网连接”。 进入右侧面板。 输入服务器的密钥对所对应的私钥文件在本地的保存路径，例如：C:\Users\Administrator\

查看更多 →

图2 BO中的字段 图3 联合主键 属性说明 在业务设计页面，从“business”中，拖拽“Value Object”对象至画布空白区域。选中对象，在右侧页面设置对象属性，如图4所示。 图4 Value Object 对象名称：设置对象的名称，必须使用大驼峰格式，不允许存在连续的大写字母。

查看更多 →

选中泳道或者某个图元，可以在右侧属性配置区域进行各种配置操作。 4 整个BPM、泳道或者图元属性设置区域。 当选择BPM中图元时，右侧配置区域为该图元的属性设置区域。 当选择BPM中空白区域时，右侧配置区域为该BPM的设置区域。 当选择泳道左侧标签时，右侧配置区域为该泳道的属性设置区域。

查看更多 →

WriteIntoKafka" + " /opt/test.jar --topic topic-test -bootstrap.servers 10.91.8.218:9092"); System.out.println("./bin/flink

查看更多 →

单击服务编排设计页面的空白处，在编辑器页面右侧选择。 在私有结构体中，单击“新增”。 创建输出参数结构体类型变量“result1”前，需要先创建私有结构体类型。 图8 添加私有结构体类型 设置私有结构体名称，成员不用定义。 图9 配置私有结构体 在服务编排设计页面右侧，单击。 在全局上下文页面，单击“对象变量”后的加号。

查看更多 →

属性配置区域 整个工作流、泳道（Lane）或图元属性设置区域。 当选择工作流中图元时，右侧配置区域为该图元的属性设置区域。 当选择工作流中空白区域时，右侧配置区域为该工作流的设置区域。 当选择泳道左侧标签时，右侧配置区域为该泳道的属性设置区域。 父主题： 工作流

查看更多 →

件说明请参考组件介绍。 图1 创建流程节点 为组件添加属性及监听器。 选择“用户任务”组件，在右侧“常规”页签中设置“名称”“责任人”“责任群组”等信息。 选择“连接箭头”组件，在右侧“常规”页签中设置“中文名称”“英文名称”，“通过条件”选择“表达式”。 常规属性设置完成后，选

查看更多 →

WebUI，如：flink_admin。 创建作业步骤 使用flink_admin登录Manager，选择“集群 > 服务 > Flink”，在“Flink WebUI”右侧，单击链接，访问Flink的WebUI。 参考如何创建FlinkServer作业，新建Flink SQL流作业，在作业开发界面进行作业开发，配置完成后启动作业。

查看更多 →

请添加当前账号对当前私有库的权限，请参考管理用户权限。 发布私有组件到PyPI私有依赖库 下载私有依赖库配置文件。 登录软件开发生产线，进入PyPI私有依赖库。单击页面右侧“操作指导”。 在弹框中找到“发布配置”，单击“下载配置文件”。 在本地将下载的“pypirc”文件另存为“.pypirc”文件。 配置代码仓库。

查看更多 →

WriteIntoKafka" + " /opt/test.jar --topic topic-test -bootstrap.servers 10.91.8.218:9092"); System.out.println("./bin/flink

查看更多 →

单击服务编排设计页面的空白处，在编辑器页面右侧选择。 在“私有结构体 > 结构体”中，单击“新增”。 创建输出参数结构体类型变量“result1”前，需要先创建私有结构体类型。 图5 添加私有结构体类型 设置私有结构体名称，成员不用定义。 图6 配置私有结构体 在服务编排设计页面右侧，单击。

查看更多 →

个节点的业务IP:2181/kafka > --list --topic <Topic名称> ./kafka-acls.sh --bootstrap-server <Kafka集群IP:21007> --command-config ../config/client.properties

查看更多 →

--replication-factor 主题的备份数 --bootstrap-server Kafka集群IP:21007 --command-config ../config/client.properties 其中，使用“--bootstrap-server”方式创建Topic时，需配置“rack

查看更多 →

单击目标服务名称，进入服务详情页面。 查看服务ID值。 在脚本中调用连接器 在脚本中，调用连接器，实现调用ModelArts的接口。 参考创建空白AstroZero脚本中操作，创建一个空白脚本。 在脚本编辑器中，输入如下代码。 import * as modelarts from 'modelarts';

查看更多 →