博客
关于我
pulsar mq 单体验证demo, docker启动pulsar mq验证生产者消费者命令
阅读量:795 次
发布时间:2023-03-04

本文共 398 字,大约阅读时间需要 1 分钟。

进入Pulsar容器并执行脚本操作

  • 进入Pulsar容器
    使用Docker命令进入容器环境:
  • docker exec -it xxx /bin/bash

    切换到bin目录:

    cd bin
    1. 消费主题
      使用Pulsar客户端工具消费指定主题:
    2. ./pulsar-client consume my-topic -s "first-subscription"
      1. 创建新的订阅
        重复上述步骤,创建新的订阅实例:
      2. ./pulsar-client consume my-topic -s "second-subscription"
        1. 发送消息
          在bin目录下,使用生产者命令发送消息:
        2. ./pulsar-client produce my-topic --messages "hello, world!"

          查看生产者和消费者的操作日志

          通过查看日志文件可以确认消息的发送和接收状态,确保Pulsar集群正常运行。

    转载地址:http://ewafk.baihongyu.com/

    你可能感兴趣的文章
    PostgreSQL删除数据库报"ERROR: There is 1 other session using the database."
    查看>>
    PostgreSQL和Oracle两种数据库有啥区别?如何选择?
    查看>>
    PostgreSQL学习总结(11)—— PostgreSQL 常用的高可用集群方案
    查看>>
    PostgreSQL学习总结(1)—— PostgreSQL 入门简介与安装
    查看>>
    PostgreSQL学习总结(2)—— PostgreSQL 语法
    查看>>
    PostgreSQL学习总结(3)—— PostgreSQL 数据类型
    查看>>
    PostgreSQL学习总结(6)—— PostgreSQL 模式(SCHEMA)详解
    查看>>
    PostgreSQL学习总结(7)—— PostgreSQL 语句 INSERT INTO、SELECT、UPDATE、DELETE 等学习
    查看>>
    PostgreSQL学习总结(8)—— PostgreSQL 基于数据库和基于模式(schema)的多租户分析
    查看>>
    PostGreSql学习笔记002---Navicat Premium中管理PostGreSql 错误:字段rolcatupdate 不存在
    查看>>
    PostgreSQL学习笔记:PostgreSQL vs MySQL
    查看>>
    PostgreSQL导入shape数据(地图工具篇.10)
    查看>>
    PostGreSql工作笔记003---在Navicat中创建数据库时报错rolcatupdate不存在_具体原因看其他博文_这里使用pgAdmin4创建管理postgre
    查看>>
    PostGreSql工作笔记004---PostGreSql修改密码_windows和linux下修改
    查看>>
    Postgresql常用命令行操作_以及Navicat操作PostGis时的问题_自动截取长度_WKB structure does not match exp---PostgreSQL工作笔记005
    查看>>
    PostgreSQL忘记密码
    查看>>
    PostgreSQL数据库pg_dump命令行不输入密码的方法
    查看>>
    PostgreSQL新手入门
    查看>>
    postgresql树状结构查询示例
    查看>>
    postgresql流复制配置
    查看>>