All Projects → pinterest → Secor

pinterest / Secor

Licence: apache-2.0
Secor is a service implementing Kafka log persistence

Programming Languages

java
68154 projects - #9 most used programming language
shell
77523 projects

Labels

Projects that are alternatives of or similar to Secor

Php Rdkafka
Production-ready, stable Kafka client for PHP
Stars: ✭ 1,703 (-1.45%)
Mutual labels:  kafka
Scrapy demo
all kinds of scrapy demo
Stars: ✭ 128 (-92.59%)
Mutual labels:  kafka
Samsara
Samsara is a real-time analytics platform
Stars: ✭ 132 (-92.36%)
Mutual labels:  kafka
Apiproject
[https://www.sofineday.com], golang项目开发脚手架,集成最佳实践(gin+gorm+go-redis+mongo+cors+jwt+json日志库zap(支持日志收集到kafka或mongo)+消息队列kafka+微信支付宝支付gopay+api加密+api反向代理+go modules依赖管理+headless爬虫chromedp+makefile+二进制压缩+livereload热加载)
Stars: ✭ 124 (-92.82%)
Mutual labels:  kafka
Docker Bro
Bro IDS Dockerfile
Stars: ✭ 126 (-92.71%)
Mutual labels:  kafka
Kafka Junit
This library wraps Kafka's embedded test cluster, allowing you to more easily create and run integration tests using JUnit against a "real" kafka server running within the context of your tests. No need to stand up an external kafka cluster!
Stars: ✭ 131 (-92.42%)
Mutual labels:  kafka
Kafka Zk Restapi
Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor
Stars: ✭ 121 (-93%)
Mutual labels:  kafka
Node Rdkafka
Node.js bindings for librdkafka
Stars: ✭ 1,799 (+4.11%)
Mutual labels:  kafka
Faust
Python Stream Processing. A Faust fork
Stars: ✭ 124 (-92.82%)
Mutual labels:  kafka
Components Contrib
Community driven, reusable components for distributed apps
Stars: ✭ 131 (-92.42%)
Mutual labels:  kafka
Azure Event Hubs For Kafka
Azure Event Hubs for Apache Kafka Ecosystems
Stars: ✭ 124 (-92.82%)
Mutual labels:  kafka
Neo4j Streams
Neo4j Kafka Integrations, Docs =>
Stars: ✭ 126 (-92.71%)
Mutual labels:  kafka
Metronome
Metronome is a distributed and fault-tolerant event scheduler
Stars: ✭ 131 (-92.42%)
Mutual labels:  kafka
Tunnel
PG数据同步工具(Java实现)
Stars: ✭ 122 (-92.94%)
Mutual labels:  kafka
Aliyun Emapreduce Datasources
Extended datasource support for Spark/Hadoop on Aliyun E-MapReduce.
Stars: ✭ 132 (-92.36%)
Mutual labels:  kafka
Slimmessagebus
Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.
Stars: ✭ 120 (-93.06%)
Mutual labels:  kafka
Abris
Avro SerDe for Apache Spark structured APIs.
Stars: ✭ 130 (-92.48%)
Mutual labels:  kafka
Goka
Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Stars: ✭ 1,862 (+7.75%)
Mutual labels:  kafka
Echo
🦄 开源社区系统:基于 SpringBoot + MyBatis + MySQL + Redis + Kafka + Elasticsearch + Spring Security + ... 并提供详细的开发文档和配套教程。包含帖子、评论、私信、系统通知、点赞、关注、搜索、用户设置、数据统计等模块。
Stars: ✭ 129 (-92.53%)
Mutual labels:  kafka
Iot Traffic Monitor
Stars: ✭ 131 (-92.42%)
Mutual labels:  kafka

Pinterest Secor

Build Status

Secor is a service persisting Kafka logs to Amazon S3, Google Cloud Storage, Microsoft Azure Blob Storage and Openstack Swift.

Key features

  • strong consistency: as long as Kafka is not dropping messages (e.g., due to aggressive cleanup policy) before Secor is able to read them, it is guaranteed that each message will be saved in exactly one S3 file. This property is not compromised by the notorious temporal inconsistency of S3 caused by the eventual consistency model,
  • fault tolerance: any component of Secor is allowed to crash at any given point without compromising data integrity,
  • load distribution: Secor may be distributed across multiple machines,
  • horizontal scalability: scaling the system out to handle more load is as easy as starting extra Secor processes. Reducing the resource footprint can be achieved by killing any of the running Secor processes. Neither ramping up nor down has any impact on data consistency,
  • output partitioning: Secor parses incoming messages and puts them under partitioned s3 paths to enable direct import into systems like Hive. day,hour,minute level partitions are supported by secor
  • configurable upload policies: commit points controlling when data is persisted in S3 are configured through size-based and time-based policies (e.g., upload data when local buffer reaches size of 100MB and at least once per hour),
  • monitoring: metrics tracking various performance properties are exposed through Ostrich, Micrometer and optionally exported to OpenTSDB / statsD,
  • customizability: external log message parser may be loaded by updating the configuration,
  • event transformation: external message level transformation can be done by using customized class.
  • Qubole interface: Secor connects to Qubole to add finalized output partitions to Hive tables.

Release Notes

Release Notes for past versions can be found in RELEASE.md.

Setup/Configuration Guide

Setup/Configuration instruction is available in README.setup.md.

Secor configuration for Kubernetes/GKE environment

Extra Setup instruction for Kubernetes/GKE environment is available in README.kubernetes.md.

Detailed design

Design details are available in DESIGN.md.

License

Secor is distributed under Apache License, Version 2.0.

Maintainers

Contributors

Companies who use Secor

Help

If you have any questions or comments, you can reach us at [email protected]

Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].