问答 2019-04-19 来自:开发者社区

各位好,咨询一个PostgreSQL的架构问题。 我希望写入PostgreSQL的动作可以被捕获并写入到指定Kafka队列中,随后异步更新到Elastic数据库。打算采用 https://debezium.io/docs/connectors/postgresql 方案,读取数据库日志流的模式,这样可以避免在程序代码层既写PostgreSQL又写Kafka带来的分布式事务问题。 在本地部署模式下这个架构没问题,但是如果采用阿里云RDS的PostgreSQL还能支持这种架构方案吗?

各位好,咨询一个PostgreSQL的架构问题。 我希望写入PostgreSQL的动作可以被捕获并写入到指定Kafka队列中,随后异步更新到Elastic数据库。打算采用 https://debezium.io/docs/connectors/postgresql 方案,读取数据库日志流的模式,这样可以避免在程序代码层既写PostgreSQL又写Kafka带来的分布式事务问题。 在本地部署模式下....

文章 2018-07-05 来自:开发者社区

搞懂分布式技术24:基于Flume+Kafka+ Elasticsearch+Storm的海量日志实时分析平台:

0背景介绍 随着机器个数的增加、各种服务、各种组件的扩容、开发人员的递增,日志的运维问题是日渐尖锐。通常,日志都是存储在服务运行的本地机器上,使用脚本来管理,一般非压缩日志保留最近三天,压缩保留最近1个月,其它直接删除或迁移到日志服务器上。 运维会将这些日志mount到远程的日志服务器上,然后开发人员使用运维分配的账号登陆堡垒机器跳转到日志服务器上查看不同项目不同机器的日志。 下图是日志服务器某....

搞懂分布式技术24:基于Flume+Kafka+ Elasticsearch+Storm的海量日志实时分析平台:
文章 2017-11-16 来自:开发者社区

Kafka项目实战-用户日志上报实时统计之分析与设计

1.概述   本课程的视频教程地址:《Kafka实战项目之分析与设计》    本课程我通过一个用户实时上报日志案例作为基础,带着大家去分析Kafka这样一个项目的各个环节,从而对项目的整体设计做比较合理的规划,最终让大家能够通过本课程去掌握类似Kafka项目的分析与设计。下面,我给大家介绍本课程包含的课时内容,如下图所示:   接下来,我们开始第一课时的学习:《项目整体概述》。 2.内容...

Kafka项目实战-用户日志上报实时统计之分析与设计
文章 2017-11-15 来自:开发者社区

ELK日志服务使用-kafka传输日志(bbotte.com)

对于日志传输,rsyslog或者logstash也就够用了,一般的redis,kafka,主要是作为缓冲或序列防止logstash挂掉后,日志中断,下面写kafka的使用。 在用kafka之前,需要rsyslog模块支持,所以需要对rsyslog升级,并且启用omkafka,下面对rsyslog升级同时加入omhiredis: 下载https://github.com/rsyslog/rsys.....

文章 2017-11-08 来自:开发者社区

kafka的topic和分区策略——log entry和消息id索引文件

Topic在逻辑上可以被认为是一个在的queue,每条消费都必须指定它的topic,可以简单理解为必须指明把这条消息放进哪个queue里。 为了使得Kafka的吞吐率可以水平扩展,物理上把topic分成一个或多个partition,每个partition在物理上对应一个文件夹,该文件 夹下存储这个partition的所有消息和索引文件。 每个日志文件都是“log entries”序列,每一个l.....

文章 2017-05-02 来自:开发者社区

基于Lua+Kafka+Heka的Nginx Log实时监控系统

背景 在我们的系统架构中,Nginx作为所有HTTP请求的入口,是非常重要的一层。每天产生大量的Nginx Access Log,闲置在硬盘上实在是太浪费资源了。所以,能不能把Nginx日志利用起来,实时监控每个业务的访问趋势、用户行为、请求质量和后端异常呢,这就是本文要探讨的主题。 目的 1. 错误码告警(499、500、502和504); 2. upstream_response_time.....

文章 2017-05-02 来自:开发者社区

Apache Kafka源码分析 – Log Management

LogManager LogManager会管理broker上所有的logs(在一个log目录下),一个topic的一个partition对应于一个log(一个log子目录) 首先loadLogs会加载每个partition所对应的log对象, 然后提供createLog,getLog,deleteLog之类的管理接口 并且会创建些后台线程来进行,cleanup,flush,checkpoint....

文章 2016-04-25 来自:开发者社区

Kafka项目实战-用户日志上报实时统计之编码实践

1.概述   本课程的视频教程地址:《Kafka实战项目之编码实践》    该课程我以用户实时上报日志案例为基础,带着大家去完成各个KPI的编码工作,实现生产模块、消费模块, 数据持久化,以及应用调度等工作, 通过对这一系列流程的演示,让大家能够去掌握Kafka项目的相关编码以及调度流程。下面,我们首先来预览本课程所包含的课时,他们分别有:   接下来,我们开始第一课时的学习:《数据生产...

文章 2016-04-25 来自:开发者社区

Kafka项目实战-用户日志上报实时统计之应用概述

1.概述   本课程的视频教程地址:《Kafka实战项目之应用概述》   本课程是通过一个用户实时上报日志来展开的,通过介绍 Kafka 的业务和应用场景,并带着大家搭建本 Kafka 项目的实战开发环境。下面我们来看看本课程有哪些课时,如下图所示:   接下来,我们开始第一课时的学习:《Kafka 回顾》。 2.内容 2.1 Kafka 回顾   本课时简述 Kafka 平台部署的注意事项,.....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云日志服务SLS

SLS是一站式云原生可观测性数据平台,一站式提供数据采集、加工、查询与分析、可视化等功能。日常更新产品最新动态,最佳实践以及技术大咖的观点和经验。

+关注