Skip to content

🌠 Purely functional Apache Pulsar client for Scala built on top of Fs2

License

Notifications You must be signed in to change notification settings

profunktor/neutron

Folders and files

NameName
Last commit message
Last commit date

Latest commit

author
gvolpe-steward[bot]
Feb 25, 2024
cb3752c Â· Feb 25, 2024
Aug 26, 2023
Nov 3, 2021
Sep 9, 2023
May 26, 2022
Sep 9, 2023
Feb 25, 2024
Apr 5, 2022
Sep 9, 2023
Nov 25, 2020
Jun 10, 2022
Sep 9, 2023
Sep 29, 2021
May 12, 2020
May 20, 2020
Oct 1, 2021
Mar 23, 2022
Sep 17, 2023
Sep 9, 2023
Feb 3, 2022
Feb 3, 2022
Apr 1, 2022
Feb 3, 2022

Repository files navigation

neutron

CI Status MergifyStatus Maven Central Scala Steward badge Cats friendly

A pulsar is a celestial object, thought to be a rapidly rotating neutron star, that emits regular pulses of radio waves and other electromagnetic radiation at rates of up to one thousand pulses per second.

pulsar

Disclaimer

Neutron started out as a fork of the original Neutron developed at Chatroulette, which was a project gvolpe started when working at that company. The main motivation for the fork was to support Scala 3, as well as adding other more opinionated changes.

Furthermore, we believe in OSS and want to maintain an Apache Pulsar library compatible with the needs of the community, and not only of the needs of a single company.

Documentation

Check out the microsite.

Development

If you have sbt installed, you don't have to worry about anything. Simply run sbt +test command in the project root to run the tests.

If you are a nix user, make sure you enter a development shell by running nix develop on the project's root.

sbt +test

Remember to first start Pulsar and its configuration via the provided shell script.

./run.sh

Schemas

Working with schemas when using our Pulsar docker-compose configuration.

Get schema compatibility strategy:

$ docker-compose exec pulsar bin/pulsar-admin namespaces get-schema-compatibility-strategy public/default
FULL

Set schema compatibility strategy:

$ docker-compose exec pulsar bin/pulsar-admin namespaces set-schema-compatibility-strategy -c BACKWARD public/default