Spring Boot 3.x Redisson Stream

My best practices for operating Redis stream with redisson client in Spring Boot 3.x

Feature

• Verify FullName(stream + group + consumer_name) not blank and duplicate, when register Listener
• com.itplh.best.practices.redisson.stream.EnhanceStreamListener add the following extensions:
  1. getMetaInfo()
  2. getStream()
  3. getGroup()
  4. getConsumerName()
  5. getFullName()
  6. getFullGroup()
• Abstract class com.itplh.best.practices.redisson.stream.AbstractAutoRetryStreamListener
  1. Automatically enable the failed retry mechanism, when the stream is single consume group
     1. default maximum retry count: 10
     2. customize the override of the 'maxRetries' method
  2. Support successful callback onSuccess
  3. Support failure callback (reaching the max retries) onFailure
  4. Support finally callback onFinally

Development Environment

• Java 21
• Redis 5.0.10
• Spring Boot 3.2.4
• redisson-spring-boot-starter 3.27.2
• Lombok 1.18.30

Sample

1. Run com.itplh.best.practices.redisson.Application
2. push data to stream

   curl --location --request GET 'http://localhost:8080/redisson/stream/push-data'

Docs

Redis Stream - Best Practices

Should XDEL be executed after XACK ?