Apache Pulsar Adapters

Clone this repo:
  1. 0adca97 Auto update partition for pulsar kafka producer (#28) by Rajan Dhabalia · 4 months ago master
  2. b363865 Import dependencies from Pulsar's parent POM (#35) by Christophe Bornet · 5 months ago
  3. 195d125 Removing Flink in favor of https://github.com/apache/flink/tree/master/flink-connectors/flink-connector-pulsar (#34) by Andrey Yegorov · 6 months ago
  4. 4ccaf7b Upgrade Log4J2 to 2.17.1 (#32) by Lari Hotari · 7 months ago
  5. ef29667 Upgrade Log4J2 to 2.15.0 to mitigate CVE-2021-44228 (#30) by Lari Hotari · 8 months ago

Apache Pulsar Adapters

This repository is used for hosting all the adapters maintained and supported by Apache Pulsar PMC.

Apache Flink adapter is supported and maintained by Apache Flink Community.


In order to build this code you can simply use Maven

mvn install

In order to build this repository the linked Pulsar release must be released to Maven Central other wise you have to build it locally.

For instance if this code depends on Pulsar 2.8.0 you have to build Pulsar 2.8.0 locally

git clone https://github.com/apache/pulsar
git checkout v2.8.0
mvn clean install -DskipTests

This is because this repository depends on test integration artifacts of the relative version on the main Apache Pulsar codebase