目前,华为云提供Kafka专享版实例的服务,Kafka专享版实例采用物理隔离的方式部署,租户独占Kafka实例。创建Kafka专享版实例之后,使用开源Kafka客户端向Kafka专享版实例生产消息和消费消息。
本章节介绍如何使用开源的Kafka客户端访问未开启SASL的Kafka专享实例的方法。
多语言客户端的使用请参考Kafka官网:https://cwiki.apache.org/confluence/display/KAFKA/Clients
访问未开启SASL的Kafka专享实例时,支持VPC内访问和公网访问两种方式,实例需要配置正确的安全组规则,具体安全组配置要求,请参考表2。
以下操作命令以Linux系统为例进行说明:
进入文件压缩包所在目录,然后执行以下命令解压文件。
tar -zxf [kafka_tar]
其中,[kafka_tar]表示命令行工具的压缩包名称。
例如:
tar -zxf kafka_2.11-1.1.0.tgz
注意,Windows系统下需要进入“/bin/windows”目录下。
./kafka-console-producer.sh --broker-list ${连接地址} --topic ${Topic名称}
参数说明如下:
本文以公网连接为例,获取的Kafka实例公网连接地址为“10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094”。执行完命令后输入内容,按“Enter”发送消息到Kafka实例,输入的每一行内容都将作为一条消息发送到Kafka实例。
[root@ecs-kafka bin]# ./kafka-console-producer.sh --broker-list 10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094 --topic topic-demo >Hello >DMS >Kafka! >^C[root@ecs-kafka bin]#
如需停止生产使用Ctrl+C命令退出。
./kafka-console-consumer.sh --bootstrap-server ${连接地址} --topic ${Topic名称} --group ${消费组名称} --from-beginning
参数说明如下:
示例如下:
[root@ecs-kafka bin]# ./kafka-console-consumer.sh --bootstrap-server 10.3.196.45:9094,10.78.42.127:9094,10.4.49.103:9094 --topic topic-demo --group order-test --from-beginning Kafka! DMS Hello ^CProcessed a total of 3 messages [root@ecs-kafka bin]#
如需停止消费使用Ctrl+C命令退出。
阿里云文件存储HDFS(Apsara File Storage for HDFS)是面向阿里云ECS实例及容器...
作者 DataWorks产品经理 陈振 一、DataWorks数据质量模块的介绍 在正式介绍数据...
本文转载自微信公众号「BAT的乌托邦」,作者YourBatman 。转载本文请联系BAT的乌...
阿里云对象存储OSS(Object Storage Service)是阿里云提供的海量、安全、低成本...
实现原理 WebSocket 协议是基于 TCP 的一种新的网络协议。它实现了浏览器与服务...
一、树结构 树是一种很特别的数据结构,树这种数据结构叫做 树 就是因为它 长得...
Java 16新特性 2021年3月16日,甲骨文正式发布了Java 16!想当年JDK1.6新出的场景...
细数那些服务器托管的注意事项 对于一个网站来讲最重要的莫过于服务器的稳定性,...
买了 域名 一定要备案吗?买了域名是否需要备案,看的是选择的什么空间服务器。 ...
三月份才过去一半,又一枚.io 域名 被爆交易。外媒称,skin.io在Park.io平台以49...