阿洋
When CMAK enables the config of "Poll consumer information", we can look at "consumer offset" , "Lag" and "Consumer Instance Owner" in /consumers/[groupId]/topic/[topicName]/type/KF URL Path for each partition. We can...
**StreamPark ── A magical framework make flink&spark easier!** # FAQ > Here is a compilation of frequently mentioned popular issues based on user feedback. If you have a new question,...
### Search before asking - [X] I had searched in the [feature](https://github.com/apache/streampark/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description StreamPark already supports multiple data sources, and the configuration file...
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened FlinkTrackController's trackIds, canceling, endpoints, jobStatuses uniformly use appId as Key....
### Describe the bug master分支，执行 "jraft-example"模块下的 election示例， com.alipay.sofa.jraft.example.election.ElectionBootstrap 的执行参数为 ``` /Users/a/Code/Java/sofa-jraft/tmp/datapath/server01 yzhougid01 127.0.0.1:2881 127.0.0.1:2881 ``` ### Expected behavior ### Actual behavior 发生异常，异常信息为： ``` 2023-08-30 15:16:25 [JRaft-FSMCaller-Disruptor-0] ERROR LogExceptionHandler:64 - Handle...
private ConcurrentHashMap _producerListeners , 假设，现在用户使用sdk 并且利用多线程，创建producer ，那么对于_producerListeners，就会出现，覆盖 ，可以利用 ConcurrentHashMap 定义 _producerListeners
//已经close closeConsumer(oldConsumerHolder); ConsumerHolder newConsumerHolder = getOrAddConsumer(topicId); if (oldConsumerHolder.getAssignments() != null) { newConsumerHolder.setAssignments(oldConsumerHolder.getAssignments()); // oldCOnsumerHolder.getConsumer() 没必须要assign了吧，作者，这里是笔误？ 有点没太明白 oldConsumerHolder.getConsumer().assign(oldConsumerHolder.getAssignments()); } else if (oldConsumerHolder.getConsumerRebalanceListener() != null) { newConsumerHolder.setConsumerRebalanceListener(oldConsumerHolder.getConsumerRebalanceListener()); newConsumerHolder.getConsumer().subscribe(Arrays.asList(topicId), oldConsumerHolder.getConsumerRebalanceListener()); } else {...
大佬们，我用的rocketmq 4.9.6， 创建了一个 消费组: group_A, 查看消费进度时，一直报错： at org.apache.rocketmq.tools.command.consumer.ConsumerProgressSubCommand.execute(ConsumerProgressSubCommand.java:240) at org.apache.rocketmq.tools.command.MQAdminStartup.main0(MQAdminStartup.java:149) at org.apache.rocketmq.tools.command.MQAdminStartup.main(MQAdminStartup.java:100) Caused by: org.apache.rocketmq.client.exception.MQClientException: CODE: 17 DESC: No topic route info in name server for the topic: %RETRY%group_A See...
一个执行时间很长的update会影响到普通 select执行吗 操作的是同一张表并且都能命中相同的索引 间隙锁 ？？？
A2：目前的设计是只支持单个 reader 的，可以把增量阶段的那个资源给它开大一些。这个设计的初衷出发点是在大部分的数据源上游的这个日志写的时候，它其实只有一个 binlog 文件，它全局是单文件的，理论上你写的话比读的开销是要大的，就是一般来读的那个开销，如果说不是一些网络或者说是资源不够，那个读是要比写要快的。