快速开始 Kafka消息队列 UKafka

ernest.wang 发布于2022-07-12 17:23 / 1515人阅读

摘要：快速开始快速开始快速开始集群访问集群访问申请集群后，系统为每个节点自动分配一个内网。以下快速开始测试来自官方。创建查看发送消息接收消息删除此命令会标记为删除状态，只有当设置为时才会真正删除数据，默认为。

快速开始

1. 集群访问

申请集群后，系统为每个 UKafka 节点自动分配一个内网 IP。kafka 服务监听 9092 端口，zookeeper 服务监听 2181 端口。

以下快速开始测试来自 Apache Kafka 官方Quickstart 。

2. 下载 Apache Kafka 代码

登陆可以 ping 通您 UKafka 集群节点的服务器。

下载 Apache Kafka 项目代码。本文选择的是 kafka_2.11-2.1.0.tgz。

解压文件夹：

$ tar -xzvf kafka_2.11-2.1.0.tgz

进入文件夹：

$ cd kafka_2.11-2.1.0/bin

3. 基本操作

请在实际测试中，将以下 [broker1 IP] 替换成您 UKafka 集群中 Broker ID 为 1 的 IP。

创建Topic

$ kafka-topics.sh --zookeeper [broker1 IP]:2181 --create --topic test_ucloud --partitions 3 --replication-factor 3
Created topic "test_ucloud".

查看Topic

$ kafka-topics.sh --zookeeper [broker1 IP]:2181 --describe --topic test_ucloud
Topic:test_ucloud   PartitionCout:3     ReplicationFactor:3    Configs:
    Topic: test_ucloud  Partition: 0    Leader: 5   Replicas: 5,1,2 Isr: 5,1,2
    Topic: test_ucloud  Partition: 1    Leader: 1   Replicas: 1,2,3 Isr: 1,2,3
    Topic: test_ucloud  Partition: 2    Leader: 2   Replicas: 2,3,4 Isr: 2,3,4

发送消息

$ kafka-console-producer.sh --broker-list [broker1 IP]:9092 --topic test_ucloud
[2016-08-11 13:42:31,788] WARN Property topic is not valid(kafka.utils.VerifiableProperties)
hello ukafka
hello ukafka

接收消息

$ kafka-console-consumer.sh --bootstrap-server [broker1 IP]:9092 --topic test_ucloud --from-beginning
hello ukafka
hello ukafka
^CConsumed 2 messages

删除Topic

$ kafka-topics.sh --zookeeper [broker1 ip]:2181 --delete --topic test_ucloud
Topic test_ucloud is marked for deletion
Note: This will have no impact if delete.topic.enable is not set to true.

此命令会标记Topic为删除状态，只有当delete.topic.enable设置为true时才会真正删除数据，默认为true。

云服务器 GPU云服务器消息队列kafka视频教程阿里云双11消息队列 Kafka组团优惠阿里云双11消息队列 Kafka有折扣吗 kafka 队列

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/126945.html

Kafka消息队列 UKafka

摘要：快速开始本例以数据同步到来做说明。创建连接器点击创建连接器按钮，打开配置页面。若下游为，则需配置路径，若为，则需填写信息。连接器列表详情页数据验证参考，为集群创建，并写入消息到其中。快速开始本例以UKafka数据同步到UHadoop来做说明。创建连接器点击【创建连接器】按钮，打开配置页面。配置连接器基本信息配置按需填写。【上游】意为Kafka连接器上游的Kafka集群，【下游】意为Kafka...

ernest.wang 2022-07-12 17:46 评论0 收藏1595
概览 Kafka消息队列 UKafka

摘要：概览概览产品简介操作指南集群管理节点管理磁盘管理管理管理监控视图监控项说明开发指南快速开始认证配置与外网访问客户端性能测试连接器产品介绍快速开始产品功能性能测试产品价格产品价格概览产品简介操作指南集群管理节点管理磁盘管理Topic管理ConsumerGroup管理监控视图监控项说明开发指南快速开始认证配置与外网访问客户端SDK性能测试FAQsKafka连接器产品介绍快速开始产品功能性能测试...

ernest.wang 2022-07-12 16:25 评论0 收藏2613
FAQs Kafka消息队列 UKafka

摘要：大量的和分区会严重影响集群性能。介绍可参考收到离线分区总数异常告警一般是某个节点宕机或者服务异常导致。若服务卡住，可在评估后在控制台重启该节点服务。若想了解当前请求延时情况，建议关注平均请求延时监控项。 FAQs本篇目录一个UKafka集群可以创建多少个Topic？如何增加Topic的副本数量(ReplicationFactor)？收到离线分区总数>=10.0个告警，离线分区总数是什么，怎么...

ernest.wang 2022-07-12 17:36 评论0 收藏2407
集群管理 Kafka消息队列 UKafka

摘要：集群管理集群管理集群管理本篇目录创建集群创建集群调整集群参数调整集群参数创建集群创建集群创建集群点击控制台左上角全部产品选择消息队列也可锁定到左侧菜单栏。选择完毕后，进入集群设置页面，可对集群参数进行配置。集群管理本篇目录创建集群调整集群参数创建集群1. 点击控制台左上角全部产品选择Kafka消息队列 UKafka,也可锁定到左侧菜单栏。2. 进入UKafka操作界面，点击创建集群进行UK...

ernest.wang 2022-07-12 17:19 评论0 收藏276
性能测试 Kafka消息队列 UKafka

摘要：性能测试性能测试性能测试上游，下游是的连接器节点数分区数数消息大小机型速度消息数核核核核核核核上游，下游是连接器节点数分区数数消息大小机型版本机型节点数分片数副本数速度消息数核核核核核核核核核性能测试上游UKafka，下游是UHadoop的HDFS 连接器节点数分区数broker数消息大小/byteskafka机型hadoopmasterhadoopcore速度(消息数/s)1331024...

ernest.wang 2022-07-12 17:26 评论0 收藏1358
性能测试 Kafka消息队列 UKafka

摘要：性能测试性能测试性能测试在不同机型集群默认配置下，利用脚本进行性能基准测试测试结果下载性能测试在不同机型 ukafka 集群默认配置下，利用 kafka-producer-perf-test.sh 脚本进行性能基准测试测试结果下载

ernest.wang 2022-07-12 16:58 评论0 收藏1086