Application for de-duplicating HFP Messages read from single/multiple Pulsar topics. Writes de-duplicated output to another Pulsar topic.
This project depends on transitdata-common project.
mvn compile
mvn package
- Run this script to build the Docker image
We're separating our unit & integration tests using this pattern.
Unit tests:
- add test classes under ./src/test with suffix *Test.java
mvn clean test -P unit-test
Integration tests:
- add test classes under ./src/integration-test with prefix IT*.java
mvn clean verify -P integration-test
Requirements:
- Local Pulsar Cluster
- By default uses localhost, override host in PULSAR_HOST if needed.
- Tip: f.ex if running inside Docker in OSX set
PULSAR_HOST=host.docker.internal
to connect to the parent machine
- Tip: f.ex if running inside Docker in OSX set
- You can use this script to launch it as Docker container
- By default uses localhost, override host in PULSAR_HOST if needed.
Launch Docker container with
docker-compose -f compose-config-file.yml up <service-name>