单击“OK”。 完成JDK选择后，单击“Apply”。 选择“Project”，在“SDK”的下拉菜单中选择在“SDKs”中添加的JDK，在“language level”下的下拉菜单中选择“8 - Lambdas, type annotations etc.”。 图4 配置Project

查看更多 →

完成JDK选择后，单击“Apply”。 选择“Project”，在“Project SDK”下的下拉菜单中选择在“SDKs”中添加的JDK，在“Project language level”下的下拉菜单中选择“8 - Lambdas, type annotations etc.”。 单击“Apply”。

查看更多 →

1协议。 在函数创建页面，新增一种函数类型“HTTP函数”； HTTP函数执行入口需要设置为bootstrap，用户直接写启动命令，端口统一开放成8000； 若运行用户JAR包，bootstrap中建议增加JVM参数-Dfile.encoding=utf-8，否则可能会出现中文乱码。

查看更多 →

length < 6) { System.err.println("Usage: SecurityKafkaWordCount <bootstrap-servers> " + "<subscribe-type> <topics> <protocol> <service>

查看更多 →

String groupId) 访问MQS提供的kafka（不开启sasl_ssl）。 输入参数 servers：kafkaConfig中的bootstrap.servers信息 groupId：kafkaConfig中的group.id信息 返回信息 返回KafkaConfig对象 public

查看更多 →

(args.length < 3) { System.err.println("Usage: KafkaWordCount <bootstrap-servers> " + "<subscribe-type> <topics>") System.exit(1)

查看更多 →

采集探针依赖的jar包。 参数值固定，均取值为：/opt/oss/servicemgr/ICAgent/pinpoint/pinpoint-bootstrap.jar -Dapm_application 应用名称。 由小写字母、数字、中划线（-）、下划线（_）组成，且以小写字母或下划线（_）开头，长度限制为1~64位字符。

查看更多 →

执行以下命令，查看待迁移的Partition对应的Topic的详细信息。 安全模式： ./kafka-topics.sh --describe --bootstrap-server Kafka集群IP:21007 --command-config ../config/client.properties

查看更多 →

(',' attr_name attr_type)* ) WITH( type = "kafka", kafka_bootstrap_servers = "", kafka_topic = "", encode = "json" ) 关键字 表1

查看更多 →

examples.WriteIntoKafka /opt/client/FlinkKafkaJavaExample.jar <topic> <bootstrap.servers> [security.protocol] [sasl.kerberos.service.name] [ssl.truststore

查看更多 →

设备向发放服务请求对应设备接入实例的引导信息。 Topic 表1 上报Topic说明 Topic $oc/devices/{device_id}/sys/bootstrap/up 消息发送方 设备 消息接收方 设备发放平台 示例 设备向发放服务发送的payload为空。 父主题： 接口说明

查看更多 →

(',' attr_name attr_type)* ) WITH( type = "kafka", kafka_bootstrap_servers = "", kafka_topic = "", encode = "json" ) 关键字 表1

查看更多 →

数据上报：如果设备在连接后，进行发放publish时，上报Topic “$oc/devices/${deviceId}/sys/bootstrap/up” 中，json上报的属性 “baseStrategyKeyword” 包含设置的关键字，即可按该实例进行发放。 一个设备最多匹配一条静态策略实例；

查看更多 →

上的运行服务，请切换到公有云。 找到需要删除的数据建模引擎，在其后单击更多图标，在弹出的下拉菜单中单击“删除”。 您也可通过服务名称链接进入详情页后，在页面右上角单击更多图标，在弹出的下拉菜单中单击“删除”。 如果待删除的数据建模引擎上有已部署的应用，则“删除”按钮不可操作。 图1

查看更多 →

er"和"--bootstrap-server"两种方式创建Topic，社区将会在后续的版本中删掉对"--zookeeper"的支持，所以建议用户使用"--bootstrap-server"的方式创建Topic。 注意：目前Kafka只支持"--bootstrap-server"

查看更多 →

完成JDK选择后，单击“Apply”。 选择“Project”，在“Project SDK”下的下拉菜单中选择在“SDKs”中添加的JDK，在“Project language level”下的下拉菜单中选择“8 - Lambdas, type annotations etc.”。 单击“Apply”。

查看更多 →

对比实例 类型：在下拉菜单中，选择类型。当前支持CPU Time、Allocated Memory、Latency以及Live Object Memory四种类型。 选择范围：在下拉菜单中，选择范围。当前支持My Code以及All Code两种范围。 选择聚合维度：在下拉菜单中，选择聚

查看更多 →

WriteIntoKafka /opt/hadoopclient/FlinkKafkaJavaExample.jar <topic> <bootstrap.servers> [security.protocol] [sasl.kerberos.service.name] [ssl.truststore

查看更多 →

rvicemgr/ICAgent/pinpoint/pinpoint-bootstrap.jar /opt/oss/servicemgr/ICAgent/pinpoint/pinpoint-bootstrap.jar -Dapm_application 应用名称，您可以结合您的应用自定义。

查看更多 →

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

查看更多 →

' attr_name attr_type)* ) WITH ( type = "kafka", kafka_bootstrap_servers = "", kafka_group_id = "", kafka_topic = "", encode

查看更多 →