Java C++ Python C Shell HTML Other
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
.github Initial import Sep 7, 2016
.test-infra/jenkins Added Groovy DSL definition for C++/Java PR builds (#1444) Mar 26, 2018
.travis Maven artifacts relases into Apache (#607) Jul 29, 2017
bin bin/bookkeeper doesn't output the result to the console (#2155) Jul 14, 2018
build/docker [website] Enable Translation & Localization (#2251) Jul 31, 2018
buildtools Bump Pulsar version to 2.2.0-incubating (#2027) Jun 26, 2018
conf Increased default brokerShutdownTimeout to 60 seconds (#2377) Aug 15, 2018
dashboard Fixed path for Postgres in dashboard docker image (#2088) Jul 6, 2018
deployment [documentation][deploy] Improve helm deployment script to deploy Puls… Aug 16, 2018
dev Fixed License header for ByteBufCoded{Input,Output}Stream.java (#1971) Jun 15, 2018
distribution [build] Fix LICENSE.bin.txt (#2395) Aug 17, 2018
docker [docker] Publish pulsar-all image to docker hub (#2361) Aug 13, 2018
jclouds-shaded GCS offload support(2): replace `s3client` api with `jclouds` related… Jul 20, 2018
managed-ledger-shaded adding a module that shades managed-ledge (#2034) Jun 26, 2018
managed-ledger [tiered storage] Provide LedgerOffloaderFactory for creating offloade… Aug 17, 2018
protobuf-shaded Bump Pulsar version to 2.2.0-incubating (#2027) Jun 26, 2018
protobuf Add ASF headers to Markdown documentation files (#823) Oct 17, 2017
pulsar-broker-auth-athenz adding a module that shades managed-ledge (#2034) Jun 26, 2018
pulsar-broker-common [tiered storage] Provide LedgerOffloaderFactory for creating offloade… Aug 17, 2018
pulsar-broker-shaded [website] Render Pulsar REST API in ReDoc and Fix endpoint template (#… Aug 1, 2018
pulsar-broker Fix some spelling typos (#2385) Aug 17, 2018
pulsar-client-admin-shaded fixing protobuf schema shading issue (#2168) Jul 16, 2018
pulsar-client-admin Issue 2283: Improve error message if authorization is not enabled (#2382 Aug 17, 2018
pulsar-client-auth-athenz Bump Pulsar version to 2.2.0-incubating (#2027) Jun 26, 2018
pulsar-client-cpp Fix some spelling typos (#2385) Aug 17, 2018
pulsar-client-go Fix some spelling typos (#2385) Aug 17, 2018
pulsar-client-kafka-compat Rename Netty native libs to reflect shading prefix (#2192) Jul 25, 2018
pulsar-client-schema [build] Configure os extension plugin at root pom (#2396) Aug 17, 2018
pulsar-client-shaded Rename Netty native libs to reflect shading prefix (#2192) Jul 25, 2018
pulsar-client-tools-test Add support to restart function (#2365) Aug 14, 2018
pulsar-client-tools Fix some spelling typos (#2385) Aug 17, 2018
pulsar-client Fix some spelling typos (#2385) Aug 17, 2018
pulsar-common Fix some spelling typos (#2385) Aug 17, 2018
pulsar-discovery-service C++ HTTP lookup works with TLS (#2314) (#2350) Aug 10, 2018
pulsar-functions [build] Configure os extension plugin at root pom (#2396) Aug 17, 2018
pulsar-io Kinesis-sink consider topic-name as partition-key if record key empty ( Aug 14, 2018
pulsar-log4j2-appender Bump Pulsar version to 2.2.0-incubating (#2027) Jun 26, 2018
pulsar-proxy Issue 2119: TopicPatternSubscription doesn't work through proxy (#2176) Jul 17, 2018
pulsar-spark adding a module that shades managed-ledge (#2034) Jun 26, 2018
pulsar-sql Fixed refcounting when processing entries from sql (#2316) Aug 7, 2018
pulsar-storm adding a module that shades managed-ledge (#2034) Jun 26, 2018
pulsar-testclient Introduce warmup period in performance producer (#2338) Aug 8, 2018
pulsar-websocket Make it possible to set idle WebSocket session timeout period (#2118) Jul 9, 2018
pulsar-zookeeper-utils adding a module that shades managed-ledge (#2034) Jun 26, 2018
pulsar-zookeeper Bump Pulsar version to 2.2.0-incubating (#2027) Jun 26, 2018
site [documentation] Fix syntax error on tiered storage documentation (#2345) Aug 8, 2018
site2 Fix some spelling typos (#2385) Aug 17, 2018
src [website] Render Pulsar REST API in ReDoc and Fix endpoint template (#… Aug 1, 2018
tests Issue 2283: Improve error message if authorization is not enabled (#2382 Aug 17, 2018
tiered-storage [tiered storage] Provide LedgerOffloaderFactory for creating offloade… Aug 17, 2018
.gitignore [website] Enable Translation & Localization (#2251) Jul 31, 2018
.travis.yml Package Pulsar IO connectors into separate tgz in form of nar archives ( Jul 2, 2018
CONTRIBUTORS.md Add ASF headers to Markdown documentation files (#823) Oct 17, 2017
DISCLAIMER Fixes for NOTICE and LICENSE files for src and bin distribution (#563) Jul 18, 2017
LICENSE Fixes for NOTICE and LICENSE files for src and bin distribution (#563) Jul 18, 2017
NOTICE Updated Copyright in NOTICE to 2017-2018 (#1664) Apr 27, 2018
README.md Add ASF headers to Markdown documentation files (#823) Oct 17, 2017
faq.md Pulsar FAQ (#1186) Feb 23, 2018
pom.xml [build] Configure os extension plugin at root pom (#2396) Aug 17, 2018

README.md

logo

Pulsar is a distributed pub-sub messaging platform with a very flexible messaging model and an intuitive client API.

https://pulsar.incubator.apache.org

Main features

  • Horizontally scalable (Millions of independent topics and millions of messages published per second)
  • Strong ordering and consistency guarantees
  • Low latency durable storage
  • Topic and queue semantics
  • Load balancer
  • Designed for being deployed as a hosted service:
    • Multi-tenant
    • Authentication
    • Authorization
    • Quotas
    • Support mixing very different workloads
    • Optional hardware isolation
  • Keeps track of consumer cursor position
  • REST API for provisioning, admin and stats
  • Geo replication
  • Transparent handling of partitioned topics
  • Transparent batching of messages

Build Pulsar

Requirements:

  • Java JDK 1.8
  • Maven

Compile and install:

$ mvn install -DskipTests

Start standalone Pulsar service:

$ bin/pulsar standalone

Check https://pulsar.incubator.apache.org for documentation and examples.

Contact

Mailing lists
Name Scope
users@pulsar.incubator.apache.org User-related discussions Subscribe Unsubscribe Archives
dev@pulsar.incubator.apache.org Development-related discussions Subscribe Unsubscribe Archives
Slack

Pulsar slack channel at https://apache-pulsar.slack.com/

You can self-register at https://apache-pulsar.herokuapp.com/

License

Licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0

Crypto Notice

This distribution includes cryptographic software. The country in which you currently reside may have restrictions on the import, possession, use, and/or re-export to another country, of encryption software. BEFORE using any encryption software, please check your country's laws, regulations and policies concerning the import, possession, or use, and re-export of encryption software, to see if this is permitted. See http://www.wassenaar.org/ for more information.

The U.S. Government Department of Commerce, Bureau of Industry and Security (BIS), has classified this software as Export Commodity Control Number (ECCN) 5D002.C.1, which includes information security software using or performing cryptographic functions with asymmetric algorithms. The form and manner of this Apache Software Foundation distribution makes it eligible for export under the License Exception ENC Technology Software Unrestricted (TSU) exception (see the BIS Export Administration Regulations, Section 740.13) for both object code and source code.

The following provides more details on the included cryptographic software: Pulsar uses the SSL library from Bouncy Castle written by http://www.bouncycastle.org.