This project includes various messaging patterns and application examples using Apache Kafka and Java.
It aims to demonstrate how messaging systems can be integrated and utilized in real-world scenarios, providing a comprehensive guide for developers working with distributed systems.
| Sample | Description |
|---|---|
| Hello world | This Spring Boot application sends a "Hello world!" message to Kafka every 5 seconds and listens to these messages with a consumer. The required Kafka topic is automatically created when the application starts. |
| File Watcher, Apache Kafka connector | This project is a custom Apache Kafka Source Connector that monitors a specified directory for file changes and publishes the content and metadata of changed files to a Kafka topic. |