参考：https://www.cnblogs.com/xiaonq/p/14097376.html 1、创建tasks.py文件进行验证 from celery import Celery import time #测试 app = Celery('TASK', broker='redis://lo ...
分类：
其他好文 时间：
2020-12-14 13:33:33
阅读次数：
4
故障症状有一个Centreon单节点监控系统（不含分布式），隔三差五的挂掉，幸好我们安排人手，时不时访问web管理后台，才没出现大的纰漏。其主要症状是Poller失效，但系统其它进程比如Apache、PHP、Centreon-engine等运行正常。在CentreonWeb管理界面重载（reload）或者重启（restart）cbd服务，无效；登录系统，执行指令systemctlstartcbd,
分类：
其他好文 时间：
2020-12-09 11:37:51
阅读次数：
8
消息丢失的场景如果KafkaProducer使用“发后即忘”的方式发送消息，即调用producer.send(msg)方法来发送消息，方法会立即返回，但此时并不能说明消息已经发送成功。消息发送方式详见初次邂逅Kafka生产者。如果在消息过程中发生了网络抖动，那么消息就会丢失；或发送的消息本身不符合要求，如大小超过Broker端的承受能力等（消息太大的情况在生产中实际遇到过，最后通过在发送前将消息分
分类：
其他好文 时间：
2020-12-08 12:53:00
阅读次数：
5
现象最近收到很多RocketMQ使用者反馈在消息发送过程中偶尔会出现如下4个错误信息之一：[REJECTREQUEST]systembusy,startflowcontrolforawhiletoomanyrequestsandsystemthreadpoolbusy,RejectedExecutionException[PC_SYNCHRONIZED]brokerbusy,startflowco
分类：
其他好文 时间：
2020-12-08 12:21:48
阅读次数：
4
温馨提示：本文基于Kafka2.2.1版本。如果觉得源码阅读比较枯燥，本文的中间有Sender线程的工作流程图。上文《源码分析Kafka消息发送流程》已经详细介绍了KafkaProducersend方法的流程，该方法只是将消息追加到KafKaProducer的缓存中，并未真正的向broker发送消息，本文将来探讨Kafka的Sender线程。在KafkaProducer中会启动一个单独的线程，其名
分类：
编程语言 时间：
2020-12-08 12:00:53
阅读次数：
6
本文将在RocketMQ消息发送systembusy、brokerbusy原因分析与解决方案的基础上，结合生产上的日志尝试再次理解brokerbusy以及探讨解决方案。首先，brokerbusy相关的日志关键字如下：[REJECTREQUEST]systembusytoomanyrequestsandsystemthreadpoolbusy[PC_SYNCHRONIZED]brokerbusy[P
分类：
其他好文 时间：
2020-12-07 12:48:48
阅读次数：
17
消息组接到某项目组反馈，topic在扩容后出现部分队列无法被消费者，导致消息积压，影响线上业务？考虑到该问题是发送在真实的线上环境，为了避免泄密，本文先在的虚拟机中来重现问题。1、案情回顾1.1集群现状集群信息如下：例如业务主体名topic_dw_test_by_order_01的路由信息如图所示：当前的消费者信息：broker的配置信息如下：brokerClusterName=DefaultCl
分类：
其他好文 时间：
2020-12-07 12:44:57
阅读次数：
13
用户自定义协议client/server代码示例 代码参考链接：https://github.com/sogou/workflow message.h message.cc server.cc client.cc 关于user_defined_protocol 本示例设计一个简单的通信协议，并在协议 ...
分类：
其他好文 时间：
2020-12-03 11:39:04
阅读次数：
3
Kafka 最初考虑的问题是，customer 应该从 brokes 拉取消息还是 brokers 将消 息推送到 consumer，也就是 pull 还 push。在这方面，Kafka 遵循了一种大部分 消息系统共同的传统的设计：producer 将消息推送到 broker，consumer 从 ...
分类：
其他好文 时间：
2020-12-03 11:32:29
阅读次数：
3
基于kerberos 加密的kafka消息我们在用spring binder链接的时候配置应当如下： #input spring.cloud.stream.bindings.process-in-0.destination=input-topic spring.cloud.stream.bindin ...
分类：
编程语言 时间：
2020-11-25 12:45:59
阅读次数：
10
