topic

系列目录 RabbitMQ 入门系列：1、MQ的应用场景的选择与RabbitMQ安装。 RabbitMQ 入门系列：2、基础含义：链接、通道、队列、交换机。 RabbitMQ 入门…

  另外找一个zk，有客户端命令的./zkCli.cmd -server 127.0.0.1:2181ls /brokers 查看注册信息 1，kafka不支持分布式事务消息 不支…

一、什么是延时消息 当消息写入到Broker后，不能立刻被消费者消费，需要等待指定的时长后才可被消费处理的消息，称为延时消息。 二、延时消息等级 RocketMQ延时消息的延迟时长…

常用命令 创建Topic： ./kafka-topics.sh –bootstrap-server localhost:9092 –create –topic shixTop…

kafka 重要参数 Broker 端参数 broker.id 每个broker都需要有一个标识符，使用broker.id来表示。它的默认值是0，也可以被设置成其他任意整数。这个值…

今天遇到一个问题，由于代码问题导致了很多kafka消息入到备用库，偏移量已经变成了最新；如何将偏移量重设到某个时间点，但消费群组重新去消费一次，是解决问题的关键，于是，使用了kaf…

一、前言 　　由于工作原因使用到了 Kafka，而现有的代码并不能满足性能需求，所以需要开发高效读写 Kafka 的工具，本文是一个 Python Kafka Client 的性能…

1、application.yml配置 spring: mqtt: username: test password: qwerty123 host-url: tcp://172.1…

☞☞☞ 我是如何将一个老系统的kafka消费者服务的性能提升近百倍的 ☜☜☜○○○○○○○☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝☝○○○○○○○○ 大家好，又见面了~ kafka作…

This code sample will show you how to send a JMS message to a topic. So if you want a to k…