最近工作中遇到需要使用kafka的场景，测试消费程序启动后，要莫名的过几十秒乃至几分钟才能成功获取到到topic的partition和offset，而后开始消费数据，于是学习了一下查看kafka broker里topic和consumer group状态的相关命令，这里记录一下。 命令参考 ...

在kafka/config/目录下面有3个配置文件： (1).producer.properties:生产端的配置文件 (2).consumer. ...

"这个Topic中发送消息： 3.启动消费者，从"accesslog"这个Topic中消费 ...

前言: mqtt 的主题一个层级的概念. 我们订阅多个主题就需要用到这个技术点 功能是在主题中引入层次。层次又分主题层级分隔符,多层通配符和单层通配符 需要注意的一点是: 这些层级不能用在发布消息的 ...

转自：https://blog.csdn.net/learn_tech/article/details/84670795 1、生产者操作： kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic ...

KAFKA 的TOPIC __consumer_offsets 的清理 查看现有的__consumer_offsets 清理策略 打印结果如下： 删除特有的清理策略 网上的资料都说 ，删除掉__consumer_offsets的特殊的清理策略后，默认会使用我们配置文件的清理 ...

正则表达式中的'/'替换 近期项目对接OneNET的MQTT物联网套件，需要完成命令下发流程. 流程要求: (1)设备在接收平台下发的命令(topic为$sys/{pid}/{device-name}/cmd/request/{cmdid}); (2)上传响应至$sys/{pid ...

最后部分的XML懒得写了，因为个人更倾向于JavaConfig形式。 为知笔记版本见这里，带格式~ 做了一个小demo，放到码云上了，有兴趣的点我。 说明：需要先了解下JMS的基础知识。 1、 ...

一般常用的类型有四种： fanout,direct,topic ,headers。 AMQP协议里还提到另外两种类型：System和自定义，这里先不说这两种，先说说常用的四种类型。 fanout: fanout会把所有发送到该交换器的消息路由到所有 ...

修改分区个数： 上面命令将test_topic对应的分区数目调整为10个，127.0.0.1是zookeeper的地址，2181是zookeeper端口。 删除topic 上面命令将主题test_topic标记为删除，但是如果delete.topic ...