angularjs和bootstrap 更多内容
  • Flink Kafka样例程序(Java)

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

    来自:帮助中心

    查看更多 →

  • Kafka用户权限说明

    群支持将Kafka的使用权限,授予不同用户。 Kafka默认用户组如表1所示。 Kafka支持两种鉴权插件:“Kafka开源自带鉴权插件”“Ranger鉴权插件”。 本章节描述的是基于“Kafka开源自带鉴权插件”的用户权限管理。如果想使用 “Ranger鉴权插件”,请参考添加Kafka的Ranger访问权限策略。

    来自:帮助中心

    查看更多 →

  • 编译并运行Flink应用

    <filePath> 指本地文件系统中文件路径,每个节点都需要放一份/opt/log1.txt/opt/log2.txt并使用chmod 755 文件名命令为用户赋予读、写、执行权限,而属组用户其他用户只有读、执行权限。可以默认,也可以自行设置。 <windowTime> 指窗口时

    来自:帮助中心

    查看更多 →

  • 使用Kafka客户端SSL加密

    properties”“consumer.properties”中的“security.protocol”的值,同时修改“producer.properties”中的“bootstrap.servers”的值,确保security.protocol协议类型bootstrap.servers中的端口号匹配。

    来自:帮助中心

    查看更多 →

  • 在Kafka Topic中接入消息

    的消费组,单击消费组名称,可查看该消费组所消费过的Topic,消费过的Topic有两种状态:“pending”“running”,分别表示“曾经消费过但现在未消费”“现在正在消费”,在弹框右上角,可以输入Topic名来进行过滤。 单击Topic名称,进入Consumer Of

    来自:帮助中心

    查看更多 →

  • Flink向Kafka生产并消费数据Scala样例代码

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

    来自:帮助中心

    查看更多 →

  • 在Kafka Topic中接入消息

    的消费组,单击消费组名称,可查看该消费组所消费过的Topic,消费过的Topic有两种状态:“pending”“running”,分别表示“曾经消费过但现在未消费”“现在正在消费”,在弹框右上角,可以输入Topic名来进行过滤。 单击Topic名称,进入Consumer Of

    来自:帮助中心

    查看更多 →

  • Flink Join样例程序(Scala)

    jar,该jar包可在Kafka客户端目录下获取。 下面列出producerconsumer,以及Flink Stream SQL Join使用主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafkacom.huawei.bigdata.flink

    来自:帮助中心

    查看更多 →

  • Flink Join样例程序(Java)

    jar,该jar包可在client目录下获取。 下面列出producerconsumer,以及Flink Stream SQL Join使用主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoKafkacom.huawei.bigdata.flink

    来自:帮助中心

    查看更多 →

  • FlinkSQL Kafka表开发规则

    name' = 'hadoop.系统 域名 ' ); SELECT * FROM KafkaSource; 不能同时设置“topic-pattern”“topic”配置项 topic-pattern:主题模式,用于source表,可使用正则表达式的主题名称。 【示例】以下source表将订

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序(Scala)

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

    来自:帮助中心

    查看更多 →

  • 基本概念

    向该版本,不再需要修改代码信息。 函数别名支持绑定两个版本,一个对应版本开启灰度版本,并且支持配置同一个别名下两个不同版本分流权重。 依赖包 依赖包管理模块统一管理用户所有的依赖包,用户可以通过本地上传obs地址的形式上传依赖包,并为依赖包命名。 函数依赖包生成示例请参考如何制作函数依赖包。

    来自:帮助中心

    查看更多 →

  • Kafka Shell命令介绍

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

    来自:帮助中心

    查看更多 →

  • Kafka Shell命令介绍

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

    来自:帮助中心

    查看更多 →

  • 添加Kafka的Ranger访问权限策略

    be”“Describe Configs”。 说明: 目前Kafka内核支持"--zookeeper""--bootstrap-server"两种方式查询Topic,社区将会在后续的版本中删掉对"--zookeeper"的支持,所以建议用户使用"--bootstrap-server"的方式查询Topic。

    来自:帮助中心

    查看更多 →

  • Spark Structured Streaming对接Kafka样例程序(Scala)

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

    来自:帮助中心

    查看更多 →

  • Spark Structured Streaming对接Kafka样例程序(Scala)

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

    来自:帮助中心

    查看更多 →

  • JBoss Standalone模式如何接入APM?

    APM支持JBoss 服务器 ,JBoss在使用Java探针时,需要特殊的设置。 下面举例对JBoss 6.2.0、JBoss 8.1.0 JBoss 12.0.0的Standalone模式接入APM进行说明,其他JBoss的版本类似操作。 JBoss 6.2.0: 将standalone模式下的eap-6

    来自:帮助中心

    查看更多 →

  • Kafka源表

    topic 是 kafka topic名。该参数“connector.topic-pattern”两个参数只能使用其中一个。 connector.topic-pattern 否 匹配读取kafka topic名称的正则表达式。该参数“connector.topic”两个参数只能使用其中一个。

    来自:帮助中心

    查看更多 →

  • Kafka源表

    topic 是 kafka topic名。该参数“connector.topic-pattern”两个参数只能使用其中一个。 connector.topic-pattern 否 匹配读取kafka topic名称的正则表达式。该参数“connector.topic”两个参数只能使用其中一个。

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序(Java)

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

    来自:帮助中心

    查看更多 →

共105条
看了本文的人还看了