kafkaclient使用 更多内容
  • 配置Flink对接Kafka安全认证

    fka组件接收数据。 确保集群安装完成,包括HDFS、Yarn、Flink和Kafka。 创建Topic。 用户使用Linux命令行创建topic,执行命令前需要使用kinit命令进行人机认证,如kinit flinkuser。 flinkuser需要用户自己创建,并拥有创建Kafka的topic权限。

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序开发思路

    found”的值修改为“true”,如图1所示。配置完后重启Kafka服务。 图1 配置用户创建topic的权限 用户使用Linux命令行创建topic,执行命令前需要使用kinit命令进行人机认证,如:kinit flinkuser。 flinkuser需要用户自己创建,并拥有创建K

    来自:帮助中心

    查看更多 →

  • 查询维护时间窗时间段

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • 查询转储任务列表

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • Flink Kafka样例程序开发思路

    found”的值修改为“true”,如图1所示。配置完后重启Kafka服务。 图1 配置用户创建topic的权限 用户使用Linux命令行创建topic,执行命令前需要使用kinit命令进行人机认证,如:kinit flinkuser。 flinkuser需要用户自己创建,并拥有创建K

    来自:帮助中心

    查看更多 →

  • 修改实例信息

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • 实例扩容

    当指定IP小于节点数量时,未指定的节点随机分配内网IP地址。 second_tenant_subnet_id 否 String 实例扩容时新节点使用备用子网的id。 当实例扩容使用备用子网,则传入此值。 需要联系客服添加白名单才能传入此值。 响应参数 状态码: 200 表3 响应Body参数 参数 参数类型

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建全量物化视图 CREATE MATERIALIZED VIEW view_name AS query; 刷新全量物化视图 REFRESH MATERIALIZED VIEW view_name; 删除物化视图 DROP MATERIALIZED VIEW view_name;

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建增量物化视图 CREATE INCREMENTAL MATERIALIZED VIEW [ view_name ] AS { query_block }; 全量刷新物化视图 REFRESH MATERIALIZED VIEW [ view_name ]; 增量刷新物化视图

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建全量物化视图 CREATE MATERIALIZED VIEW view_name AS query; 刷新全量物化视图 REFRESH MATERIALIZED VIEW view_name; 删除物化视图 DROP MATERIALIZED VIEW view_name;

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建全量物化视图 CREATE MATERIALIZED VIEW [ view_name ] AS { query_block }; 全量刷新物化视图 REFRESH MATERIALIZED VIEW [ view_name ]; 删除物化视图 DROP MATERIALIZED

    来自:帮助中心

    查看更多 →

  • 删除后台任务管理中的指定记录

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • 关闭Smart Connect(按需实例)

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • 暂停Smart Connect任务

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • 启动已暂停的Smart Connect任务

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • 查询项目标签

    .withAk(ak) .withSk(sk); KafkaClient client = KafkaClient.newBuilder() .withCredential(auth)

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建全量物化视图 CREATE MATERIALIZED VIEW [ view_name ] AS { query_block }; 刷新全量物化视图 REFRESH MATERIALIZED VIEW [ view_name ]; 删除物化视图 DROP MATERIALIZED

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建全量物化视图 CREATE MATERIALIZED VIEW [ view_name ] AS { query_block }; 刷新全量物化视图 REFRESH MATERIALIZED VIEW [ view_name ]; 删除物化视图 DROP MATERIALIZED

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建增量物化视图 CREATE INCREMENTAL MATERIALIZED VIEW view_name AS query; 全量刷新物化视图 REFRESH MATERIALIZED VIEW view_name; 增量刷新物化视图 REFRESH INCREMENTAL

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建全量物化视图 CREATE MATERIALIZED VIEW [ view_name ] AS { query_block }; 全量刷新物化视图 REFRESH MATERIALIZED VIEW [ view_name ]; 删除物化视图 DROP MATERIALIZED

    来自:帮助中心

    查看更多 →

  • 使用

    使用 语法格式 创建增量物化视图 CREATE INCREMENTAL MATERIALIZED VIEW [ view_name ] AS { query_block }; 全量刷新物化视图 REFRESH MATERIALIZED VIEW [ view_name ]; 增量刷新物化视图

    来自:帮助中心

    查看更多 →

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