(Optional) Start a Redis server:
redis-server
Start the stream listener app:
./gradlew bootRun
Generate messages using RIOT Gen:
riot-gen import --end 10000000 id=#index xadd --keyspace events
You should see stats printed in the stream listener app console:
-- Meters ----------------------------------------------------------------------
eventsConsumed
count = 743850
mean rate = 43687.26 events/second
1-minute rate = 49792.70 events/second
5-minute rate = 49818.97 events/second
15-minute rate = 49826.11 events/second
The stream listener is a Spring Boot app, and like all Spring Boot apps can be configured using program arguments such as:
--spring.redis.host=myhost --spring.redis.port=6380 ...
With gradle you can configure the app using the --args
option:
./gradlew bootRun --args="--spring.redis.host=myhost --spring.redis.port=6380"
These additional references should also help you: