首页 > 其他分享 >kafka生产者、消费者-命令行模式模拟

kafka生产者、消费者-命令行模式模拟

时间:2024-09-26 11:03:58浏览次数:1  
标签:bat group 生产者 server topic -- 命令行 kafka

win环境下,如果是linux,切换目录,用sh脚本就行

kafka安装在上一篇 https://www.cnblogs.com/qcy-blog/p/18428599

Kraft启动kafka

kafka-server-start.bat ..\..\config\kraft\server.properties

生产者,启动之后,命令行输入要生产的消息

kafka-console-producer.bat --topic test-topic --bootstrap-server 192.168.252.1:9092

kafka的消费者是分组的,也就是相同的group认为是一组,同一组下,多个消费者,只能有一个消费者能消费到消息。

想要做成发布订阅模式,就做成group名字不一样

消费者1

kafka-console-consumer.bat --topic test-topic --bootstrap-server 192.168.252.1:9092 --group group1

消费者2

kafka-console-consumer.bat --topic test-topic --bootstrap-server 192.168.252.1:9092 --group group2

标签:bat,group,生产者,server,topic,--,命令行,kafka
From: https://www.cnblogs.com/qcy-blog/p/18433040

相关文章

  • ELK+zookeeper+kafka+rsyslog集群搭建
    前言环境困境:1.开发人员无法登陆服务器2.各系统都有日志,日志数据分散难以查找3.日志数据量大,查询忙,不能实时环境要求:1.日志需要标准化 集群流程图: 角色: 软件:以上软件都可以从官网下载:https://www.elastic.co/download......
  • Nginx 反向代理 apache kafka UI
    背景我将apachekafkaUI部署到Linux服务器上了,然后我不能直接链接到服务器IP和端口。需要nginx做代理。我这里假设apachekafkaUI已经能够正常连接kafka了。步骤在apachekafkaUI所在的服务器上面设置环境变量[root@kafka1apachekafkaUI]#exportSERVER_SERVLET_CONT......
  • kafka的安装与配置
    kafka的安装与配置kafka的安装在这我才用的是oracle云,系统是Ubuntu,在docker上按照的安装docker具体的安装方法请见docker-compose教程查看docker版本docker--versionDockerversion27.0.3,build7d4bcd8创建DockerCompose文件Kafka依赖Zookeeper来管理集群,因......
  • AutoMQ:云原生 Kafka 解决方案,降低10倍成本100%完美兼容
    文章目录AutoMQ:云原生Kafka的全新演绎概述设计理念存储分离至共享云存储服务可靠性与可用性分离AutoMQ的技术优势1.成本效益2.极致弹性3.冷热数据隔离4.服务零中断5.与ApacheKafka完全兼容AutoMQ部署与验证一键安装操作指南创建Topic发送消息消费消息总结公众号,感谢......
  • Android 设备命令行开代理
    #!/bin/bashecho"\n----------------Support------------------"echo"设置默认代理proxyset"echo"设置自定义代理proxyset****:9090"echo"删除代理proxyclean"echo"------------------------------------------......
  • kafka集群架构与原理
    前言    这次我们从消息队列开始讨论。生产者-消费者模型中间需要一个消息队列,以存储生产者的产品。对传统的消息队列来说,它支持点对点(P2P)和发布/订阅(Pub/Sub)两种消息模型。在点对点模型中,消息被发送到一个队列,并且只有一个消费者可以消费该消息。在发布/订阅模型中,消......
  • kafka负载均衡迁移(通过kafka eagle)
    在grafana监控中发现kafka的各个节点磁盘不均匀出现这样的情况是因为kafka默认是以文件数作为平衡的条件的。换句话说,kafka不会管一个副本有多大,只会看磁盘中有多少个副本文件。解决方式:1、修改策略,改为按照磁盘大小平衡数据2、手动迁移数据,将磁盘使用率高的节点数据迁移......
  • kafka安装
    新版本支持kraft,并且在后面会彻底抛弃zookeeper二进制包地址https://downloads.apache.org/kafka/解压之后,编辑config/kraft/server.properties文件,改成自己的ip在Kafka安装目录的bin文件夹下执行以下命令生成一个新的集群ID,如果只有1个机器也没关系,windows的命令在windows......
  • 多线程之手撕生产者-消费者
    要点维护一个资源(在生产者-消费者中即流水线的位置)池,实现put()/get()两个函数。由于对信号量的操作是互斥的,要引入条件变量和信号量。实现资源池类Pool,成员变量:mtx:mutexcv:condition_variableque:queuecapacity:int实现资源池类Pool,成员函数:Tget():获取......
  • Kafka初学
    Kafka初学概念介绍Kafka是最初由Linkedin公司开发,是一个分布式、多分区、多副本、多生产者、多订阅者,基于zookeeper协调的分布式日志系统(或者说MQ系统),常见可以用于web/nginx日志、访问日志、消息服务等等,Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目应用场景日志......