rocketMQ手动创建Topic
参数解释如下： 在灰度环境扩展消费者机器，需要手动创建Topic，命令如下： ...
原文：kafka 高级应用 springboot2.1 (2) 手动创建topic
依赖： application.properties: KafkaConfig: 如果topic需要初始化：可以配置 cankao :https: blog.csdn.net tmeng article details test 手动创建topic ,手动查看所有topic ...
2019-09-18 17:53 0 2069 推荐指数：
相关推荐
kafka手动拉取消费Topic
一般在SpringBoot使用kafka，通常用@KafkaListener注解来进行监听消费。然而某些时候，我们不需要监听而要以定时拉取的方式进行消费，本文主要就是简单记录此方式的实现方法。 (备注：主要涉及依赖：spring-kafka、hutool) 文章转载自 ...
手动创建springboot项目
1. 创建一个maven项目 2. POM文件中导入依赖 3. 创建主方法 4. 为了测试创建一个控制器 ...
手动创建后仍然提示 topic[] not exist, apply first please
昨天晚上同事碰到个问题，rocketMq 在test和dev环境创建的topic ，默认是自动创建的没有问题，但是在pre环境却不行。日志里面提示是 就是没有找到对应的topic，按说应该是自动创建的，但是手动创建后仍然不行。 这好奇 ...
kafka手动设置offset
项目中经常有需求不是消费kafka队列全部的数据，取区间数据 查询kafka最大的offset: ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.1.4:9092 --topic zhangyi ...
Kafka手动提交 offset
虽然自动提交offset十分简单便利，但由于其是基于时间提交的，开发人员难以把握offset提交的时机。因 此Kafka还提供了手动提交offset的API。手动提交offset的方法有两种:分别是commitSync(同步提交)和commitAsync(异步提交)。两者的相 同点 ...
springBoot 手动注入Bean
1.创建一个DefinitionRegistryPostProcessor ： 2.测试能否在spring上下文获取该bean： 3.测试类： 结果： ...
Druid手动创建连接的坑
环境：druid 1.1.10 今天优化了一天的代码, 老代码手动创建连接，坑 当你close关闭连接的时候，实际与数据库的物理连接并未关闭, 用Jmeter 1000个并发压测一下就报Too Many connection 解决方案： 1.改为druid原来的连接池 ...