刘旭

Results 10 issues of 刘旭

## What problem does this feature solve? 官网能不能提供一个方案来处理打包结果过大的问题,还有一个就是打包速度特别慢,启动一次需要60-70秒钟,打包完成一次需要90s以上, ## What does the proposed API look like? 官网能不能提供一个方案来处理打包结果过大的问题,还有一个就是打包速度特别慢,启动一次需要60-70秒钟,打包完成一次需要90s以上,

Need More Info
Need Reproduce :telescope:

**Which Component** spring-cloud-starter-stream-rocketmq组件 **Describe what problem you have encountered** 现在遇到了一个进退两难的问题。 场景:有个服务msg-hub需要使用spring-cloud-stream连接三个RocketMQ集群,然后随着日积月累,会核每个集群大概400个Topic产生连接,看到关于和RocketMQ的生产者的线程数达到: 2000多个,在容器内出现OOM。目前排查到的原因如下: 1. 当使用spring-cloud-stream的StreamBridge通过send方法发送消息给某个RocketMQ集群的时候,StreamBridge会使用: binder(集群名字) + ":" + Topic 作为维度建立一个MessageChannel对象 2. MessageChannel对象是spring-cloud-stream对多类型MQ的一个客户端的封装,向下具体化为RocketMQ的就是RocketMQProducerMessageHandler对象 3. RocketMQProducerMessageHandler对象包含一个defaultMQProducer对象(DefaultMQProducer类型) 4. 每个defaultMQProducer会创建一个新的MQClientInstance对象,原因是:clientId每次都不一样,这个不一样出在: instanceName这块上 5. RocketMQProduceFactory在初始化defaultMQProducer的时候,会执行如下的代码设置instanceName这个属性 ```java...

Loki版本:2.9.1 部署模式: loki mircoservice 部署的组件: gateway:1 distributor: 3 ingester: 3 querier: 1 现在出现的问题是: ingester-0 ingester-1 ingester-2 三个副本,总是出现ingester-2这个副本出现OOM kill导致重启,但是但是ingester-0 和ingester-1内存使用就很平稳 后面看了下distributor和ingester的交互,是通过hash ring来做选择交互的,这个hash数值是从提交过来的log stream获取到labels来计算的。也就是说,如果一个服务器上的日志,如果标签都是一致的,恰巧这个服务器的日志又很多,如果按照Loki的distributor的原理,这些日志都会朝向一个ingester服务发送请求,也就是问题当中的ingester-2(我是按照这个逻辑猜测)。 那么对于这种日志量大,可能会产生一个ingester服务累死,其他的ingester很空闲的情况,如何处理? ************************************************************************************************************************** Google translate Loki distributed deployment mode,...

**Describe the issue** When define dynamic-destination-cache-size ,the channelCache execute removeEldestEntry method,the bindingService can found key The reason is ,when we create a new MessageChannel object put channelCache,the code is: ```java...

Triaging

- [x] I have searched the [issues](https://github.com/alibaba/canal/issues) of this repository and believe that this is not a duplicate. - [x] I have checked the [FAQ](https://github.com/alibaba/canal/wiki/FAQ) of this repository and believe...

Path:/zh-CN/docs/3.0/admin-manual/data-admin/ccr/overview 看到这个页面给出了ccr-syncer的工具,但是看到在3.0.4版本的时候,给出的还是ccr-syncer-3.0.4-rc02-arm64.tar.xz. 是不是写错了?

### Before Creating the Bug Report - [x] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions). - [x] I have searched the...

**The context** What do you wish to achieve? **The question** Our applications are all on k8s, and communication between services uses k8s service or headless service. However, when we use...

question

When I execute the following code, an error occurs ```rust fn dump_metadata() -> Result { let mut client = KafkaClient::new(vec!["172.16.1.118:9092".to_string()]); client.load_metadata_all().map_err(|e| e.to_string())?; let topics = { let topics = client.topics();...

We introduced pyroscope.jar as an agent. After the process worked for about 20 minutes, we found that the jvm_threads_daemon_thread indicator obtained from spring-boot-actuator gradually changed from positive to negative. When...