A starter app for testing out your Apache Kafka deployment and trying out the Vert.x Kafka client.
The app allows you to send records to a topic in Kafka called test every two seconds and consume back those records.
Test out the app by connecting to the websocket endpoints (UI will be added soon!):
- Make sure Kafka is running locally. (You can use the quickstart guide)
- Build the app:
mvn install - Start the app:
java -jar target/demo-0.0.1-SNAPSHOT-fat.jar - Connect to
ws://localhost:8080/demoproduce - Start sending records to Kafka by sending the following message to the websocket:
The websocket will receive notifications every time the app sends a new record to Kafka.
{"action":"start"} - Stop sending records by sending the following message to the websocket:
{"action":"stop"} - Disconnect from the produce websocket
- Connect to
ws://localhost:8080/democonsume - Start consuming from Kafka by sending the following message to the websocket:
The websocket will receive information about all the consumed records.
{"action":"start"} - Stop consuming records by sending the following message to the websocket:
{"action":"stop"} - Disconnect from the consume websocket
To configure the application to connect to your Kafka edit the properties file in src/main/resources.
If your Kafka is secured you will need to enable the security configuration options and add your certificate to src/main/resources.