ES7的X-pack许可证是提供免费一个月的试用，但是到期之后，就会隔一段时间报这个错误elasticsearch_1| {"type": "server", "timestamp": "2020-09-09T04:14:51,347Z", "level": "ERROR", "component": "o.e.x.s.a.f.SecurityActionFilter", "cluster.nam

Kafka CommitFailedException 异常怎么处理？CommitFailedException，顾名思义就是 Consumer 客户端在提交位移时出现了错误或异常，而且还是那种不可恢复的严重异常。如果异常是可恢复的瞬时错误，提交位移的 API 自己就能规避它们了，因为很多提交位移的 API 方法是支持自动错误重试的，比如commitSync()。每次和 CommitFailedE

Kafka 生产者压缩算法说起压缩（compression），我相信你一定不会感到陌生。它秉承了用时间去换空间的经典 trade-off 思想，具体来说就是用 CPU 时间去换磁盘空间或网络 I/O 传输量，希望以较小的 CPU 开销带来更少的磁盘占用或更少的网络 I/O 传输。在 Kafka 中，压缩也是用来做这件事的。今天我就来跟你分享一下 Kafka 中压缩的那些事儿。怎么压缩Kafka 是

如何监控 Kafka 消费者组消费进度？对于 Kafka 消费者来说，最重要的事情就是监控它们的消费进度了，或者说是监控它们消费的滞后程度。这个滞后程度有个专门的名称：消费者 Lag 或 Consumer Lag。所谓滞后程度，就是指消费者当前落后于生产者的程度。比方说，Kafka 生产者向某主题成功生产了 100 万条消息，你的消费者当前消费了 80 万条消息，那么我们就说你的消费者滞后了 20

Kafka 中的消费者位移 __consumer_offsets__consumer_offsets 在 Kafka 源码中有个更为正式的名字，叫位移主题，即 Offsets Topic。老版本 Consumer 的位移管理是依托于 Apache ZooKeeper 的，它会自动或手动地将位移数据提交到 ZooKeeper 中保存。当 Consumer 重启后，它能自动从 ZooKeeper 中读

文章目录架构设计主要构件及其相互关系总体流程加载配置并初始化接收调用请求处理操作请求架构设计我们把MyBatis的功能架构分为三层：API接口层提供给外部使用的接口API，开发人员通过这些本地API来操作数据库。接口层接到调用请求就会调用数据处理层来完成具体的数据处理MyBatis和数据库交互有两种方式：使用传统的MyBatis提供的API使用Mapper代理的方式数据处理层负责具体的SQL查找、

{"query": {"bool": {"must": [],"filter": [{"bool": {"should": [{"match": {"reason": "使用物品"}}],