Prerequisites:
- Java 21
- Maven
- Docker
Once your docker environment is configured, you can run the integration tests with maven:
- To demonstrate producing and consuming messages from a Transactional Event Queue topic using Kafka APIs, run the OKafkaExampleIT test.
mvn integration-test -Dit.test=OKafkaExampleIT
- To demonstrate a transactional producer, run the TransactionalProduceIT test. With a transactional producer, messages are only produced if the producer successfully commits the transaction.
mvn integration-test -Dit.test=TransactionalProduceIT
- To demonstrate a transactional consumer, run the TransactionalConsumeIT test.
mvn integration-test -Dit.test=TransactionalConsumeIT
To run all the Transactional Event Queue Kafka API tests, run mvn integration-test
.