Flink EMQX Connector

Quick start

See WordCount.java for a simple example to get started.

Developing

Building

mvn clean package
# without running tests
mvn clean package -DskipTests

Testing

mvn clean test
# Run specific test suite
mvn clean -Dtest=EMQXSourceIntegrationTests test
# Run specific test case
mvn clean -Dtest=EMQXSourceIntegrationTests#recoverAfterFailure test