tencent cloud

文档反馈

运行 Kafka 客户端(可选)

最后更新时间:2024-05-30 18:04:14

    操作场景

    该任务指导您在购买 CKafka 服务后,使用 Kafka API。本地下载并解压 Kafka 工具包,并对 Kafka API 进行简单测试。

    操作步骤

    步骤1:安装 JDK 环境

    1. 检查 Java 安装。
    打开终端,执行如下命令:
    java -version
    如果输出 Java 版本号,说明 Java 安装成功;如果没有安装 Java,请 下载安装 Java 软件开发套件(JDK)
    2. 设置 Java 环境。
    设置 JAVA_HOME 环境变量,并指向您机器上的 Java 安装目录。 以 Java JDK 1.8.0_20 版本为例,操作系统的输出如下:
    操作系统
    输出
    Windows
    Set the environment variable JAVA_HOME to
    C:\\Program Files\\Java\\jdkjdk1.8.0_20
    Linux
    export JAVA_HOME=/usr/local/java-current
    Mac OSX
    export JAVA_HOME=/Library/Java/Home
    将 Java 编译器地址添加到系统路径中:
    操作系统
    输出
    Windows
    将字符串“;C:\\Program Files\\Java\\jdk1.8.0_20\\bin”添加到系统变量“Path”的末尾
    Linux
    export PATH=$PATH:$JAVA_HOME/bin/
    Mac OSX
    not required
    使用上面提到的 java -version 命令验证 Java 安装。

    步骤2:下载 Kafka 工具包

    下载并解压 Kafka 安装包。(Kafka 安装包官网下载地址

    步骤3:Kafka API 测试

    1. 在本地配置 ACL 策略。
    1.1 在工具包 ./config 目录下,在 producer.properties 和 consumer.properties 文件末尾添加以下内容:
    security.protocol=SASL_PLAINTEXT
    sasl.mechanism=PLAIN
    1.2 创建一个名为 ckafka_client_jaas.conf 的文件,内容如下:
    KafkaClient {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="yourinstance#yourusername"
    password="yourpassword";
    };
    说明:
    username 是实例 ID + # + 刚配置的用户名,password 是刚配置的用户密码。
    1.3 在工具包 ./bin 目录下,在 kafka-console-producer.sh 和 kafka-console-consumer.sh 文件起始部位增加对 JAAS 文件的路径的声明(必须是完整路径):
    export KAFKA_OPTS="-Djava.security.auth.login.config=****/config/ckafka_client_jaas.conf"
    2. 通过 CLI 命令生产和消费消息,去到./bin目录下。
    2.1 打开终端启动消费者。
    bash kafka-console-consumer.sh --bootstrap-server XXXX:port --topic XXXX --consumer.config ../config/consumer.properties
    说明:
    broker-list:将 XXXX:port 替换成公网访问的域名与端口,在控制台实例详情页面的接入方式模块获取。
    
    topic:将 XXXX 替换成 topic 名称,在控制台 topic 管理页面获取。
    2.2 另外开一个终端窗口启动生产者。
    bash kafka-console-producer.sh --broker-list XXXX:port --topic XXXX --producer.config ../config/producer.properties
    说明:
    broker-list:将 XXXX:port 替换成公网访问的域名与端口,在控制台实例详情页面的接入方式模块获取。
    
    topic:将 XXXX 替换成 topic 名称,在控制台 topic 管理页面获取。
    输入消息内容之后按回车,即可看到消费端也几乎同时收到消息。
    生产消息:
    
    消费消息:
    
    3. 在 CKafka 控制台消息查询页面,查询刚刚发送的消息内容。
    
    消息详情如下:
    
    联系我们

    联系我们,为您的业务提供专属服务。

    技术支持

    如果你想寻求进一步的帮助,通过工单与我们进行联络。我们提供7x24的工单服务。

    7x24 电话支持