Skip to content
Apache Pulsar - distributed pub-sub messaging system
Branch: master
Clone or download
jerrypeng fix: NPE when stats manager not initialized (#3891)
* fix: NPE when stats manager not initialized

* remove unnecessary imports

* add test
Latest commit dfc0e0e Mar 23, 2019
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
.github [dev] PIP 27: Add checklist in github pull request template (#3252) Jan 17, 2019
.test-infra/jenkins Removed mentions to incubator-pulsar (#2620) Sep 25, 2018
.travis Maven artifacts relases into Apache (#607) Jul 29, 2017
bin [logging] make root log level configurable (#3661) Mar 2, 2019
build/docker Added support for ZSTD compression (#3159) Jan 24, 2019
buildtools Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
conf [pulsar-broker] Fix deadlock: add zk-operation timeout for blocking c… Mar 19, 2019
dashboard Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
deployment Revert "Remove broker mode to handle persistent/non-persistent topics… Mar 1, 2019
dev Fixed License header for ByteBufCoded{Input,Output}Stream.java (#1971) Jun 15, 2018
distribution hide kafka-connecter details for easy use debezium connector (#3825) Mar 19, 2019
docker-compose/standalone-dashboard Add sample docker-compose file with pulsar standalone (#2617) Sep 24, 2018
docker Use `PULSAR_PREFIX_` for appending new keys (#3858) Mar 19, 2019
examples Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
jclouds-shaded Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
managed-ledger-shaded Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
managed-ledger Create ManagedCursor with initial properties (#3857) Mar 20, 2019
protobuf-shaded version not match in protobuf-shaded/pom.xml (#3824) Mar 15, 2019
protobuf Add ASF headers to Markdown documentation files (#823) Oct 17, 2017
pulsar-broker-auth-athenz Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-broker-auth-sasl kerberos: authentication between client and broker (#3821) Mar 19, 2019
pulsar-broker-common [pulsar-broker] Fix deadlock: add zk-operation timeout for blocking c… Mar 19, 2019
pulsar-broker-shaded Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-broker Namespace service should not use static variable maps (#3888) Mar 24, 2019
pulsar-client-1x-base add reset cousor to a specific publish time (#3622) Feb 28, 2019
pulsar-client-admin-shaded Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-client-admin [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partition… Mar 4, 2019
pulsar-client-all PIP-29: One package for both pulsar client and pulsar admin (#3662) Feb 22, 2019
pulsar-client-api revise the schema default type not null (#3752) Mar 19, 2019
pulsar-client-auth-athenz Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-client-auth-sasl kerberos: authentication between client and broker (#3821) Mar 19, 2019
pulsar-client-cpp Enable generation of swagger definitions for functions/sources/sinks (#… Mar 22, 2019
pulsar-client-go fix message_id_serialize to empty slice (#3801) Mar 14, 2019
pulsar-client-kafka-compat Add a wrapper around Kafka's ProducerInterceptor to support Kafka's P… Mar 20, 2019
pulsar-client-shaded Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-client-tools-test [Issue #3436][pulsar-broker] Creating REST Endpoint for non-partition… Mar 4, 2019
pulsar-client-tools [pulsar-client-tools] Add support for websocket produce/consume comma… Mar 19, 2019
pulsar-client fix some LGTM alerts (#3531) Mar 20, 2019
pulsar-common fix some LGTM alerts (#3531) Mar 20, 2019
pulsar-discovery-service [pulsar-broker] Fix deadlock: add zk-operation timeout for blocking c… Mar 19, 2019
pulsar-flink Added support for "negative acks" in Java client (#3703) Mar 7, 2019
pulsar-functions fix: NPE when stats manager not initialized (#3891) Mar 24, 2019
pulsar-io revise the schema default type not null (#3752) Mar 19, 2019
pulsar-log4j2-appender Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-proxy [pulsar-broker] Fix deadlock: add zk-operation timeout for blocking c… Mar 19, 2019
pulsar-spark Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-sql revise the schema default type not null (#3752) Mar 19, 2019
pulsar-storm Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
pulsar-testclient improvement doc of `--auth-params` in `pulsar-client` cli (#3605) Feb 22, 2019
pulsar-websocket [pulsar-broker] Fix deadlock: add zk-operation timeout for blocking c… Mar 19, 2019
pulsar-zookeeper-utils [pulsar-broker] Fix deadlock: add zk-operation timeout for blocking c… Mar 19, 2019
pulsar-zookeeper Bumped version to 2.4.0-SNAPSHOT (#3604) Feb 15, 2019
site fix document description bugs (#3740) Mar 7, 2019
site2 Enable generation of swagger definitions for functions/sources/sinks (#… Mar 22, 2019
src Enable generation of swagger definitions for functions/sources/sinks (#… Mar 22, 2019
tests issue#3838 : Allow incompatible schemas to co-exist on a topic, allow… Mar 19, 2019
tiered-storage fix s3 spport for s3 api (#3845) Mar 19, 2019
.gitignore [Pulsar-Flink] Rename Flink examples sub-module (#3266) Dec 31, 2018
.travis.yml Fixes to get the travis build running again (#3204) Dec 17, 2018
CONTRIBUTORS.md Add ASF headers to Markdown documentation files (#823) Oct 17, 2017
LICENSE Fixes for NOTICE and LICENSE files for src and bin distribution (#563) Jul 18, 2017
NOTICE Update copyright year in NOTICE files to 2019 (#3283) Jan 3, 2019
README.md Update README.md (#3841) Mar 20, 2019
faq.md Removed mentions to incubator-pulsar (#2620) Sep 25, 2018
pom.xml kerberos: authentication between client and broker (#3821) Mar 19, 2019

README.md

logo

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

https://pulsar.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.apache.org for documentation and examples.

Setting up your IDE

Apache Pulsar is using lombok so you have to ensure your IDE setup with required plugins.

Intellij

To configure annotation processing in IntelliJ:

  1. Open Annotation Processors Settings dialog box by going to Settings -> Build, Execution, Deployment -> Compiler -> Annotation Processors.

  2. Select the following buttons:

    1. "Enable annotation processing"
    2. "Obtain processors from project classpath"
    3. "Store generated sources relative to: Module content root"
  3. Set the generated source directories to be equal to the Maven directories:

    1. Set "Production sources directory:" to "target/generated-sources/annotations".
    2. Set "Test sources directory:" to "target/generated-test-sources/test-annotations".
  4. Click “OK”.

  5. Install the lombok plugin in intellij.

Eclipse

Follow the instructions here to configure your Eclipse setup.

Build Pulsar docs

Refer to the docs README.

Contact

Mailing lists
Name Scope
users@pulsar.apache.org User-related discussions Subscribe Unsubscribe Archives
dev@pulsar.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.

You can’t perform that action at this time.